APPS.ECX_OUT_WF_QH dependencies on DBMS_AQ

Line 9: x_dequeue_options dbms_aq.dequeue_options_t;

5: PROCEDURE Dequeue(p_agent_guid in RAW, p_event out NOCOPY WF_EVENT_T)
6: is
7: x_queue_name varchar2(80);
8: x_agent_name varchar2(30);
9: x_dequeue_options dbms_aq.dequeue_options_t;
10: x_message_properties dbms_aq.message_properties_t;
11: x_msgid RAW(16);
12: x_clob clob;
13: no_messages exception;

Line 10: x_message_properties dbms_aq.message_properties_t;

6: is
7: x_queue_name varchar2(80);
8: x_agent_name varchar2(30);
9: x_dequeue_options dbms_aq.dequeue_options_t;
10: x_message_properties dbms_aq.message_properties_t;
11: x_msgid RAW(16);
12: x_clob clob;
13: no_messages exception;
14: pragma exception_init (no_messages, -25228);

Line 49: x_dequeue_options.wait := dbms_aq.no_wait;

45: x_to_agt := wf_agent_t(x_agent_name, x_sys_name);
46:
47: wf_event_t.initialize(p_event);
48:
49: x_dequeue_options.wait := dbms_aq.no_wait;
50: x_dequeue_options.navigation := ecx_out_wf_qh.navigation;
51:
52: begin
53: dbms_aq.dequeue

Line 53: dbms_aq.dequeue

49: x_dequeue_options.wait := dbms_aq.no_wait;
50: x_dequeue_options.navigation := ecx_out_wf_qh.navigation;
51:
52: begin
53: dbms_aq.dequeue
54: (
55: queue_name => x_queue_name,
56: dequeue_options => x_dequeue_options,
57: message_properties => x_message_properties,

Line 62: ecx_out_wf_qh.navigation := dbms_aq.next_message;

58: payload => x_ecxmsg,
59: msgid => x_msgid
60: );
61:
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;

Line 108: ecx_out_wf_qh.navigation := dbms_aq.first_message;

104: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
105: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
106: 'No more messages in dequeue.');
107: end if;
108: ecx_out_wf_qh.navigation := dbms_aq.first_message;
109: p_event := NULL;
110: return;
111: end;
112:

Line 238: x_enqueue_options dbms_aq.enqueue_options_t;

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;
239: x_message_properties dbms_aq.message_properties_t;
240: l_in_clob clob;
241: l_out_clob clob;
242: l_module varchar2(2000);

Line 239: x_message_properties dbms_aq.message_properties_t;

235: x_msgid out NOCOPY raw
236: )
237: is
238: x_enqueue_options dbms_aq.enqueue_options_t;
239: x_message_properties dbms_aq.message_properties_t;
240: l_in_clob clob;
241: l_out_clob clob;
242: l_module varchar2(2000);
243:

Line 268: DBMS_AQ.ENQUEUE

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,
271: enqueue_options => x_enqueue_options,
272: message_properties => x_message_properties,