APPS.WF_EVENT_QH dependencies on DBMS_AQ

Line 6: p_wait in binary_integer default dbms_aq.no_wait)

2: /* $Header: wfquhndb.pls 120.3.12020000.4 2013/04/09 17:08:19 skandepu ship $ */
3: ------------------------------------------------------------------------------
4: PROCEDURE dequeue(p_agent_guid in raw,
5: p_event out nocopy wf_event_t,
6: p_wait in binary_integer default dbms_aq.no_wait)
7: is
8: x_queue_name varchar2(80);
9: x_agent_name varchar2(30);
10: x_dequeue_options dbms_aq.dequeue_options_t;

Line 10: x_dequeue_options dbms_aq.dequeue_options_t;

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

Line 11: x_message_properties dbms_aq.message_properties_t;

7: is
8: x_queue_name varchar2(80);
9: x_agent_name varchar2(30);
10: x_dequeue_options dbms_aq.dequeue_options_t;
11: x_message_properties dbms_aq.message_properties_t;
12: x_msgid RAW(16);
13: no_messages exception;
14: pragma exception_init (no_messages, -25228);
15: --Define the snapshot too old error

Line 102: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,

98: x_dequeue_options.navigation := wf_event.getQueueNavigation;
99:
100:
101: BEGIN
102: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,
103: dequeue_options => x_dequeue_options,
104: message_properties => x_message_properties, /* OUT */
105: payload => p_event, /* OUT */
106: msgid => x_msgid); /* OUT */

Line 108: -- wf_event.navigation := dbms_aq.next_message;

104: message_properties => x_message_properties, /* OUT */
105: payload => p_event, /* OUT */
106: msgid => x_msgid); /* OUT */
107:
108: -- wf_event.navigation := dbms_aq.next_message;
109: EXCEPTION
110: when no_messages then
111: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
112: wf_log_pkg.string(wf_log_pkg.level_event,

Line 126: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,

122: when snap_too_old then
123: -- reset navigation
124: wf_event.resetNavigationParams;
125: x_dequeue_options.navigation := wf_event.getQueueNavigation;
126: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,
127: dequeue_options => x_dequeue_options,
128: message_properties => x_message_properties, /* OUT */
129: payload => p_event, /* OUT */
130: msgid => x_msgid); /* OUT */

Line 160: x_enqueue_options dbms_aq.enqueue_options_t;

156: x_to_agent_name varchar2(30);
157: x_to_system_name varchar2(30);
158: x_out_queue varchar2(80);
159: x_to_queue varchar2(80);
160: x_enqueue_options dbms_aq.enqueue_options_t;
161: x_message_properties dbms_aq.message_properties_t;
162: x_msgid RAW(16);
163: x_name varchar2(30);
164: x_address varchar2(1024);

Line 161: x_message_properties dbms_aq.message_properties_t;

157: x_to_system_name varchar2(30);
158: x_out_queue varchar2(80);
159: x_to_queue varchar2(80);
160: x_enqueue_options dbms_aq.enqueue_options_t;
161: x_message_properties dbms_aq.message_properties_t;
162: x_msgid RAW(16);
163: x_name varchar2(30);
164: x_address varchar2(1024);
165: x_protocol varchar2(30);

Line 287: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',

283: end if;
284: END IF;
285: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
286: wf_log_pkg.string(wf_log_pkg.level_statement,
287: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
288: 'calling dbms_aq.enqueue');
289: end if;
290:
291: DBMS_AQ.ENQUEUE(

Line 288: 'calling dbms_aq.enqueue');

284: END IF;
285: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
286: wf_log_pkg.string(wf_log_pkg.level_statement,
287: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
288: 'calling dbms_aq.enqueue');
289: end if;
290:
291: DBMS_AQ.ENQUEUE(
292: queue_name => x_out_queue,

Line 291: DBMS_AQ.ENQUEUE(

287: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
288: 'calling dbms_aq.enqueue');
289: end if;
290:
291: DBMS_AQ.ENQUEUE(
292: queue_name => x_out_queue,
293: enqueue_options => x_enqueue_options,
294: message_properties => x_message_properties,
295: payload => p_event,

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

300:
301: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
302: wf_log_pkg.string(wf_log_pkg.level_procedure,
303: 'wf.plsql.WF_EVENT_QH.enqueue.End',
304: 'finished calling dbms_aq.enqueue');
305: end if;
306:
307: exception
308: when others then