17: payloadl IN NUMBER
18: )
19: AS
20:
21: l_ecx_dequeue_options DBMS_AQ.dequeue_options_t;
22: l_ecx_message_properties DBMS_AQ.message_properties_t;
23: l_ecx_message_handle RAW (16);
24: l_ecx_message SYSTEM.ecxmsg;
25: l_jms_enqueue_options DBMS_AQ.enqueue_options_t;
18: )
19: AS
20:
21: l_ecx_dequeue_options DBMS_AQ.dequeue_options_t;
22: l_ecx_message_properties DBMS_AQ.message_properties_t;
23: l_ecx_message_handle RAW (16);
24: l_ecx_message SYSTEM.ecxmsg;
25: l_jms_enqueue_options DBMS_AQ.enqueue_options_t;
26: l_jms_message_properties DBMS_AQ.message_properties_t;
21: l_ecx_dequeue_options DBMS_AQ.dequeue_options_t;
22: l_ecx_message_properties DBMS_AQ.message_properties_t;
23: l_ecx_message_handle RAW (16);
24: l_ecx_message SYSTEM.ecxmsg;
25: l_jms_enqueue_options DBMS_AQ.enqueue_options_t;
26: l_jms_message_properties DBMS_AQ.message_properties_t;
27: l_jms_message_handle RAW (16);
28: l_jms_message SYS.aq$_jms_text_message;
29: l_error_msg VARCHAR2 (1000);
22: l_ecx_message_properties DBMS_AQ.message_properties_t;
23: l_ecx_message_handle RAW (16);
24: l_ecx_message SYSTEM.ecxmsg;
25: l_jms_enqueue_options DBMS_AQ.enqueue_options_t;
26: l_jms_message_properties DBMS_AQ.message_properties_t;
27: l_jms_message_handle RAW (16);
28: l_jms_message SYS.aq$_jms_text_message;
29: l_error_msg VARCHAR2 (1000);
30: l_payload_length NUMBER;
49: WHILE (l_more_messages) LOOP
50:
51: BEGIN
52: l_ecx_dequeue_options.deq_condition := 'tab.USER_DATA.PARTY_SITE_ID = ''XNB''';
53: l_ecx_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
54:
55:
56: DBMS_AQ.DEQUEUE(queue_name => g_apps_schema||'.'||g_ecx_outbound_q
57: ,dequeue_options => l_ecx_dequeue_options
52: l_ecx_dequeue_options.deq_condition := 'tab.USER_DATA.PARTY_SITE_ID = ''XNB''';
53: l_ecx_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
54:
55:
56: DBMS_AQ.DEQUEUE(queue_name => g_apps_schema||'.'||g_ecx_outbound_q
57: ,dequeue_options => l_ecx_dequeue_options
58: ,message_properties => l_ecx_message_properties
59: ,payload => l_ecx_message
60: ,msgid => l_ecx_message_handle);
121: -- ENQUEUE ON JMS OUTBOUND QUEUE
122: --
123: ------------------------------------------------------------
124:
125: dbms_aq.enqueue(queue_name => g_apps_schema||'.'||g_xnb_jms_outbound_q
126: ,enqueue_options => l_jms_enqueue_options
127: ,message_properties => l_jms_message_properties
128: ,payload => l_jms_message
129: ,msgid => l_jms_message_handle);
163: payloadl IN NUMBER
164: )
165: AS
166:
167: l_jms_dequeue_options DBMS_AQ.dequeue_options_t;
168: l_jms_message_properties DBMS_AQ.message_properties_t;
169: l_jms_message_handle RAW (16);
170: l_jms_message SYS.aq$_jms_text_message;
171: l_ecx_enqueue_options DBMS_AQ.enqueue_options_t;
164: )
165: AS
166:
167: l_jms_dequeue_options DBMS_AQ.dequeue_options_t;
168: l_jms_message_properties DBMS_AQ.message_properties_t;
169: l_jms_message_handle RAW (16);
170: l_jms_message SYS.aq$_jms_text_message;
171: l_ecx_enqueue_options DBMS_AQ.enqueue_options_t;
172: l_ecx_message_properties DBMS_AQ.message_properties_t;
167: l_jms_dequeue_options DBMS_AQ.dequeue_options_t;
168: l_jms_message_properties DBMS_AQ.message_properties_t;
169: l_jms_message_handle RAW (16);
170: l_jms_message SYS.aq$_jms_text_message;
171: l_ecx_enqueue_options DBMS_AQ.enqueue_options_t;
172: l_ecx_message_properties DBMS_AQ.message_properties_t;
173: l_ecx_message_handle RAW (16);
174: l_ecx_message SYSTEM.ecxmsg;
175: l_error_msg VARCHAR2 (1000);
168: l_jms_message_properties DBMS_AQ.message_properties_t;
169: l_jms_message_handle RAW (16);
170: l_jms_message SYS.aq$_jms_text_message;
171: l_ecx_enqueue_options DBMS_AQ.enqueue_options_t;
172: l_ecx_message_properties DBMS_AQ.message_properties_t;
173: l_ecx_message_handle RAW (16);
174: l_ecx_message SYSTEM.ecxmsg;
175: l_error_msg VARCHAR2 (1000);
176: l_payload_length NUMBER;
195: BEGIN
196:
197: -- l_jms_dequeue_options.msgid := descr.msg_id;
198:
199: l_jms_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
200:
201:
202: DBMS_AQ.DEQUEUE( queue_name => g_apps_schema||'.'||g_xnb_jms_inbound_q
203: ,dequeue_options => l_jms_dequeue_options
198:
199: l_jms_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
200:
201:
202: DBMS_AQ.DEQUEUE( queue_name => g_apps_schema||'.'||g_xnb_jms_inbound_q
203: ,dequeue_options => l_jms_dequeue_options
204: ,message_properties => l_jms_message_properties
205: ,payload => l_jms_message
206: ,msgid => l_jms_message_handle);
291: -- ENQUEUE ON ECX INBOUND QUEUE
292: --
293: ------------------------------------------------------------
294:
295: dbms_aq.enqueue(queue_name => g_apps_schema||'.'||g_ecx_inbound_q
296: ,enqueue_options => l_ecx_enqueue_options
297: ,message_properties => l_ecx_message_properties
298: ,payload => l_ecx_message
299: ,msgid => l_ecx_message_handle);