DBA Data[Home] [Help]

APPS.ECX_INBOUND_LISTENER_QH dependencies on DBMS_AQ

Line 44: x_dequeue_options dbms_aq.dequeue_options_t;

40: PROCEDURE Dequeue(p_agent_guid in RAW, p_event out nocopy WF_EVENT_T)
41: is
42: x_queue_name varchar2(80);
43: x_agent_name varchar2(30);
44: x_dequeue_options dbms_aq.dequeue_options_t;
45: x_message_properties dbms_aq.message_properties_t;
46: x_msgid RAW(16);
47: x_clob clob;
48: no_messages exception;

Line 45: x_message_properties dbms_aq.message_properties_t;

41: is
42: x_queue_name varchar2(80);
43: x_agent_name varchar2(30);
44: x_dequeue_options dbms_aq.dequeue_options_t;
45: x_message_properties dbms_aq.message_properties_t;
46: x_msgid RAW(16);
47: x_clob clob;
48: no_messages exception;
49: pragma exception_init (no_messages, -25228);

Line 95: dbms_aq.dequeue

91: x_dequeue_options.wait := 1;
92:
93: savepoint before_dequeue;
94:
95: dbms_aq.dequeue
96: (
97: queue_name => x_queue_name,
98: dequeue_options => x_dequeue_options,
99: message_properties => x_message_properties,

Line 233: x_enqueue_options dbms_aq.enqueue_options_t;

229: p_out_agent_override in wf_agent_t )
230: is
231:
232: x_out_queue varchar2(80);
233: x_enqueue_options dbms_aq.enqueue_options_t;
234: x_message_properties dbms_aq.message_properties_t;
235: x_msgid RAW(16);
236: x_ecxmsg SYSTEM.ecxmsg ;
237: l_module varchar2(2000);

Line 234: x_message_properties dbms_aq.message_properties_t;

230: is
231:
232: x_out_queue varchar2(80);
233: x_enqueue_options dbms_aq.enqueue_options_t;
234: x_message_properties dbms_aq.message_properties_t;
235: x_msgid RAW(16);
236: x_ecxmsg SYSTEM.ecxmsg ;
237: l_module varchar2(2000);
238:

Line 273: DBMS_AQ.ENQUEUE

269:
270: x_message_properties.priority := p_event.GetPriority();
271:
272:
273: DBMS_AQ.ENQUEUE
274: (
275: queue_name => x_out_queue,
276: enqueue_options => x_enqueue_options,
277: message_properties => x_message_properties,

Line 284: 'finished calling dbms_aq.enqueue');

280: );
281:
282: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
283: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module || '.end',
284: 'finished calling dbms_aq.enqueue');
285: end if;
286:
287: exception
288: when others then