DBA Data[Home] [Help]

APPS.XNB_QUEUE_HANDLERS_PKG dependencies on DBMS_AQ

Line 21: l_ecx_dequeue_options DBMS_AQ.dequeue_options_t;

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;

Line 22: l_ecx_message_properties DBMS_AQ.message_properties_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;

Line 25: l_jms_enqueue_options DBMS_AQ.enqueue_options_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);

Line 26: l_jms_message_properties DBMS_AQ.message_properties_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);
30: l_payload_length NUMBER;

Line 53: l_ecx_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;

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

Line 56: DBMS_AQ.DEQUEUE(queue_name => g_apps_schema||'.'||g_ecx_outbound_q

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);

Line 125: dbms_aq.enqueue(queue_name => g_apps_schema||'.'||g_xnb_jms_outbound_q

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);

Line 167: l_jms_dequeue_options DBMS_AQ.dequeue_options_t;

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;

Line 168: l_jms_message_properties DBMS_AQ.message_properties_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;

Line 171: l_ecx_enqueue_options DBMS_AQ.enqueue_options_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);

Line 172: l_ecx_message_properties DBMS_AQ.message_properties_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);
176: l_payload_length NUMBER;

Line 199: l_jms_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;

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

Line 202: DBMS_AQ.DEQUEUE( queue_name => g_apps_schema||'.'||g_xnb_jms_inbound_q

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);

Line 295: dbms_aq.enqueue(queue_name => g_apps_schema||'.'||g_ecx_inbound_q

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);