11: x_msgid RAW(16);
12: x_clob clob;
13: no_messages exception;
14: pragma exception_init (no_messages, -25228);
15: x_ecxmsg system.ecxmsg;
16: x_sys_guid RAW(16);
17: x_sys_name VARCHAR2(30);
18: x_from_agt wf_agent_t := wf_agent_t(null,null);
19: x_to_agt wf_agent_t := wf_agent_t(null,null);
54: (
55: queue_name => x_queue_name,
56: dequeue_options => x_dequeue_options,
57: message_properties => x_message_properties,
58: payload => x_ecxmsg,
59: msgid => x_msgid
60: );
61:
62: ecx_out_wf_qh.navigation := dbms_aq.next_message;
62: ecx_out_wf_qh.navigation := dbms_aq.next_message;
63:
64: p_event.priority := 1;
65: p_event.event_name := 'oracle.apps.ecx.inbound.message.receive';
66: p_event.event_key := x_ecxmsg.document_number;
67: p_event.from_agent := x_from_agt ;
68: p_event.to_agent := x_to_agt ;
69: p_event.error_subscription := null;
70: p_event.error_message := null;
75: 'setting message props');
76: end if;
77:
78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
76: end if;
77:
78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
77:
78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
78: --p_event.AddParameterToList('ECX_MSGID', x_msgid);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
79: p_event.AddParameterToList('TRANSACTION_TYPE', x_ecxmsg.transaction_type);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
80: p_event.AddParameterToList('TRANSACTION_SUBTYPE', x_ecxmsg.transaction_subtype);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
81: p_event.AddParameterToList('MESSAGE_STANDARD', x_ecxmsg.message_standard);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
82: p_event.AddParameterToList('MESSAGE_TYPE', x_ecxmsg.message_type);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
83: p_event.AddParameterToList('DOCUMENT_NUMBER', x_ecxmsg.document_number);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
84: p_event.AddParameterToList('PARTYID', x_ecxmsg.partyid);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
85: p_event.AddParameterToList('PARTY_SITE_ID', x_ecxmsg.party_site_id);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
86: p_event.AddParameterToList('PROTOCOL_TYPE', x_ecxmsg.protocol_type);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
87: p_event.AddParameterToList('PROTOCOL_ADDRESS', x_ecxmsg.protocol_ADDRESS);
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:
88: p_event.AddParameterToList('USERNAME', x_ecxmsg.username);
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:
96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
89: p_event.AddParameterToList('PASSWORD', x_ecxmsg.password);
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:
96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
97: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
90: p_event.AddParameterToList('ATTRIBUTE1', x_ecxmsg.attribute1);
91: p_event.AddParameterToList('ATTRIBUTE2', x_ecxmsg.attribute2);
92: p_event.AddParameterToList('ATTRIBUTE3', x_ecxmsg.attribute3);
93: p_event.AddParameterToList('ATTRIBUTE4', x_ecxmsg.attribute4);
94: p_event.AddParameterToList('ATTRIBUTE5', x_ecxmsg.attribute5);
95:
96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
97: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
98: 'setting payload');
96: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
97: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
98: 'setting payload');
99: end if;
100: p_event.setEventData(x_ecxmsg.payload);
101:
102: exception
103: when no_messages then
104: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
118:
119:
120: /**
121: This procedure traverses through all the parameters in wf_event_t object, constructs the
122: system.ecxmsg object and returns these to the caller procedure
123: **/
124: procedure create_ecxmsg(p_event in wf_event_t,
125: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg
126: )
120: /**
121: This procedure traverses through all the parameters in wf_event_t object, constructs the
122: system.ecxmsg object and returns these to the caller procedure
123: **/
124: procedure create_ecxmsg(p_event in wf_event_t,
125: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg
126: )
127: is
128:
121: This procedure traverses through all the parameters in wf_event_t object, constructs the
122: system.ecxmsg object and returns these to the caller procedure
123: **/
124: procedure create_ecxmsg(p_event in wf_event_t,
125: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg
126: )
127: is
128:
129: i_param_list wf_parameter_list_t;
134: l_module varchar2(2000);
135:
136: begin
137:
138: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue.create_ecxmsg';
139: -- loop through the parameter list and construct x_ecxmsg object
140: i_param_list := p_event.getParameterList();
141: if (i_param_list is null) then
142: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
135:
136: begin
137:
138: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue.create_ecxmsg';
139: -- loop through the parameter list and construct x_ecxmsg object
140: i_param_list := p_event.getParameterList();
141: if (i_param_list is null) then
142: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
143: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
148: ecx_out_wf_qh.retmsg :='ECX_PARAM_LIST_NOT_NULL';
149: ecx_out_wf_qh.retcode := 2;
150: raise queue_handler_exit;
151: else
152: x_ecxmsg := SYSTEM.ecxmsg(null, null, null, null, null, null, null, null, null,
153: null, null, null, null, null, null, null, null, null);
154: for i in i_param_list.first..i_param_list.last loop
155: i_param_name := i_param_list(i).GetName;
156: i_param_value := i_param_list(i).GetValue;
155: i_param_name := i_param_list(i).GetName;
156: i_param_value := i_param_list(i).GetValue;
157:
158: if i_param_name = 'MESSAGE_TYPE' then
159: x_ecxmsg.message_type := i_param_value;
160:
161: elsif i_param_name = 'MESSAGE_STANDARD' then
162: x_ecxmsg.message_standard := i_param_value;
163:
158: if i_param_name = 'MESSAGE_TYPE' then
159: x_ecxmsg.message_type := i_param_value;
160:
161: elsif i_param_name = 'MESSAGE_STANDARD' then
162: x_ecxmsg.message_standard := i_param_value;
163:
164: elsif i_param_name = 'TRANSACTION_TYPE' then
165: x_ecxmsg.transaction_type := i_param_value;
166:
161: elsif i_param_name = 'MESSAGE_STANDARD' then
162: x_ecxmsg.message_standard := i_param_value;
163:
164: elsif i_param_name = 'TRANSACTION_TYPE' then
165: x_ecxmsg.transaction_type := i_param_value;
166:
167: elsif i_param_name = 'TRANSACTION_SUBTYPE' then
168: x_ecxmsg.transaction_subtype := i_param_value;
169:
164: elsif i_param_name = 'TRANSACTION_TYPE' then
165: x_ecxmsg.transaction_type := i_param_value;
166:
167: elsif i_param_name = 'TRANSACTION_SUBTYPE' then
168: x_ecxmsg.transaction_subtype := i_param_value;
169:
170: elsif i_param_name = 'DOCUMENT_NUMBER' then
171: x_ecxmsg.document_number := i_param_value;
172:
167: elsif i_param_name = 'TRANSACTION_SUBTYPE' then
168: x_ecxmsg.transaction_subtype := i_param_value;
169:
170: elsif i_param_name = 'DOCUMENT_NUMBER' then
171: x_ecxmsg.document_number := i_param_value;
172:
173: elsif i_param_name = 'PARTY_TYPE' then
174: x_ecxmsg.party_type := i_param_value;
175:
170: elsif i_param_name = 'DOCUMENT_NUMBER' then
171: x_ecxmsg.document_number := i_param_value;
172:
173: elsif i_param_name = 'PARTY_TYPE' then
174: x_ecxmsg.party_type := i_param_value;
175:
176: elsif i_param_name = 'PARTYID' then
177: x_ecxmsg.partyid := i_param_value;
178:
173: elsif i_param_name = 'PARTY_TYPE' then
174: x_ecxmsg.party_type := i_param_value;
175:
176: elsif i_param_name = 'PARTYID' then
177: x_ecxmsg.partyid := i_param_value;
178:
179: elsif i_param_name = 'PARTY_SITE_ID' then
180: x_ecxmsg.party_site_id := i_param_value;
181:
176: elsif i_param_name = 'PARTYID' then
177: x_ecxmsg.partyid := i_param_value;
178:
179: elsif i_param_name = 'PARTY_SITE_ID' then
180: x_ecxmsg.party_site_id := i_param_value;
181:
182: elsif i_param_name = 'PROTOCOL_TYPE' then
183: x_ecxmsg.protocol_type := i_param_value;
184:
179: elsif i_param_name = 'PARTY_SITE_ID' then
180: x_ecxmsg.party_site_id := i_param_value;
181:
182: elsif i_param_name = 'PROTOCOL_TYPE' then
183: x_ecxmsg.protocol_type := i_param_value;
184:
185: elsif i_param_name = 'PROTOCOL_ADDRESS' then
186: x_ecxmsg.protocol_address := i_param_value;
187:
182: elsif i_param_name = 'PROTOCOL_TYPE' then
183: x_ecxmsg.protocol_type := i_param_value;
184:
185: elsif i_param_name = 'PROTOCOL_ADDRESS' then
186: x_ecxmsg.protocol_address := i_param_value;
187:
188: elsif i_param_name = 'USERNAME' then
189: x_ecxmsg.username := i_param_value;
190:
185: elsif i_param_name = 'PROTOCOL_ADDRESS' then
186: x_ecxmsg.protocol_address := i_param_value;
187:
188: elsif i_param_name = 'USERNAME' then
189: x_ecxmsg.username := i_param_value;
190:
191: elsif i_param_name = 'PASSWORD' then
192: x_ecxmsg.password := i_param_value;
193:
188: elsif i_param_name = 'USERNAME' then
189: x_ecxmsg.username := i_param_value;
190:
191: elsif i_param_name = 'PASSWORD' then
192: x_ecxmsg.password := i_param_value;
193:
194: elsif i_param_name = 'ATTRIBUTE1' then
195: x_ecxmsg.attribute1 := i_param_value;
196:
191: elsif i_param_name = 'PASSWORD' then
192: x_ecxmsg.password := i_param_value;
193:
194: elsif i_param_name = 'ATTRIBUTE1' then
195: x_ecxmsg.attribute1 := i_param_value;
196:
197: elsif i_param_name = 'ATTRIBUTE2' then
198: x_ecxmsg.attribute2 := i_param_value;
199:
194: elsif i_param_name = 'ATTRIBUTE1' then
195: x_ecxmsg.attribute1 := i_param_value;
196:
197: elsif i_param_name = 'ATTRIBUTE2' then
198: x_ecxmsg.attribute2 := i_param_value;
199:
200: elsif i_param_name = 'ATTRIBUTE3' then
201: x_ecxmsg.attribute3 := i_param_value;
202:
197: elsif i_param_name = 'ATTRIBUTE2' then
198: x_ecxmsg.attribute2 := i_param_value;
199:
200: elsif i_param_name = 'ATTRIBUTE3' then
201: x_ecxmsg.attribute3 := i_param_value;
202:
203: elsif i_param_name = 'ATTRIBUTE4' then
204: x_ecxmsg.attribute4 := i_param_value;
205:
200: elsif i_param_name = 'ATTRIBUTE3' then
201: x_ecxmsg.attribute3 := i_param_value;
202:
203: elsif i_param_name = 'ATTRIBUTE4' then
204: x_ecxmsg.attribute4 := i_param_value;
205:
206: elsif i_param_name = 'ATTRIBUTE5' then
207: x_ecxmsg.attribute5 := i_param_value;
208: end if;
203: elsif i_param_name = 'ATTRIBUTE4' then
204: x_ecxmsg.attribute4 := i_param_value;
205:
206: elsif i_param_name = 'ATTRIBUTE5' then
207: x_ecxmsg.attribute5 := i_param_value;
208: end if;
209: end loop;
210: end if;
211:
212: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
213: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
214: 'setting payload');
215: end if;
216: x_ecxmsg.payload := p_event.getEventData();
217:
218: exception
219: when queue_handler_exit then
220: raise queue_handler_exit;
221: when others then
222: ecx_out_wf_qh.retmsg := SQLERRM;
223: ecx_out_wf_qh.retcode := 2;
224: raise queue_handler_exit;
225: end create_ecxmsg;
226:
227:
228: /**
229: This procedure enqueues the message on ecx_outqueue and returns the msgid of this message
230: **/
231: procedure enqueue_msg(
232: x_out_queue in varchar2,
233: i_protocol_type in out NOCOPY varchar2,
234: x_ecxmsg in out NOCOPY SYSTEM.ecxmsg,
235: x_msgid out NOCOPY raw
236: )
237: is
238: x_enqueue_options dbms_aq.enqueue_options_t;
260: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
261: 'Correlation id: '|| x_message_properties.correlation);
262: end if;
263:
264: l_in_clob := x_ecxmsg.payload;
265: ecx_eng_utils.convertEncryCodeClob(l_in_clob, l_out_clob);
266: x_ecxmsg.payload := l_out_clob;
267:
268: DBMS_AQ.ENQUEUE
262: end if;
263:
264: l_in_clob := x_ecxmsg.payload;
265: ecx_eng_utils.convertEncryCodeClob(l_in_clob, l_out_clob);
266: x_ecxmsg.payload := l_out_clob;
267:
268: DBMS_AQ.ENQUEUE
269: (
270: queue_name => x_out_queue,
269: (
270: queue_name => x_out_queue,
271: enqueue_options => x_enqueue_options,
272: message_properties => x_message_properties,
273: payload => x_ecxmsg,
274: msgid => x_msgid
275: );
276:
277: -- assign the encrpyted clob back to x_ecxmsg so it will insert the
273: payload => x_ecxmsg,
274: msgid => x_msgid
275: );
276:
277: -- assign the encrpyted clob back to x_ecxmsg so it will insert the
278: -- encrpyted clob to ecx_doclogs later.
279: x_ecxmsg.payload := l_in_clob;
280:
281: if dbms_lob.istemporary(l_out_clob) = 1 then
275: );
276:
277: -- assign the encrpyted clob back to x_ecxmsg so it will insert the
278: -- encrpyted clob to ecx_doclogs later.
279: x_ecxmsg.payload := l_in_clob;
280:
281: if dbms_lob.istemporary(l_out_clob) = 1 then
282: dbms_lob.freetemporary(l_out_clob);
283: end if;
313: x_to_system_name varchar2(30);
314: x_out_queue varchar2(80);
315: x_to_queue varchar2(80);
316: x_msgid RAW(16);
317: x_ecxmsg SYSTEM.ecxmsg;
318: l_module varchar2(2000);
319:
320: cursor c1
321: is
349: where agt.name = x_out_agent_name
350: and sys.name = x_out_system_name
351: and sys.guid = agt.system_guid;
352:
353: create_ecxmsg (p_event, x_ecxmsg);
354:
355: -- enqueue the message
356: ecx_out_wf_qh.enqueue_msg(
357: x_out_queue => x_out_queue,
354:
355: -- enqueue the message
356: ecx_out_wf_qh.enqueue_msg(
357: x_out_queue => x_out_queue,
358: i_protocol_type => x_ecxmsg.protocol_type,
359: x_ecxmsg => x_ecxmsg,
360: x_msgid => x_msgid
361: );
362:
355: -- enqueue the message
356: ecx_out_wf_qh.enqueue_msg(
357: x_out_queue => x_out_queue,
358: i_protocol_type => x_ecxmsg.protocol_type,
359: x_ecxmsg => x_ecxmsg,
360: x_msgid => x_msgid
361: );
362:
363: -- set msgid