DBA Data[Home] [Help]

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.1.12000000.2 2007/07/03 04:03:38 sstomar 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 75: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,

71: x_dequeue_options.navigation := wf_event.navigation;
72:
73:
74: BEGIN
75: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,
76: dequeue_options => x_dequeue_options,
77: message_properties => x_message_properties, /* OUT */
78: payload => p_event, /* OUT */
79: msgid => x_msgid); /* OUT */

Line 81: wf_event.navigation := dbms_aq.next_message;

77: message_properties => x_message_properties, /* OUT */
78: payload => p_event, /* OUT */
79: msgid => x_msgid); /* OUT */
80:
81: wf_event.navigation := dbms_aq.next_message;
82: EXCEPTION
83: when no_messages then
84: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
85: wf_log_pkg.string(wf_log_pkg.level_event,

Line 90: wf_event.navigation := dbms_aq.first_message;

86: 'wf.plsql.WF_EVENT_QH.dequeue.queue_empty',
87: 'No more messages in dequeue.');
88: end if;
89:
90: wf_event.navigation := dbms_aq.first_message;
91: p_event := NULL;
92: return;
93: --Capture the snapshot too old error
94: when snap_too_old then

Line 98: if (wf_event.navigation = dbms_aq.FIRST_MESSAGE) then

94: when snap_too_old then
95: --Workaround for AQ when receiving ORA-01555 using NEXT_MESSAGE as
96: --navigation. We will try to set to FIRST_MESSAGE and dequeue to
97: --silently handle this exception.
98: if (wf_event.navigation = dbms_aq.FIRST_MESSAGE) then
99: raise;
100: else
101: -- if wf_dequeue is called indivudiually, we should return the event.
102: -- because the consumer doesn't know the navigation_option.

Line 103: wf_event.navigation := dbms_aq.FIRST_MESSAGE;

99: raise;
100: else
101: -- if wf_dequeue is called indivudiually, we should return the event.
102: -- because the consumer doesn't know the navigation_option.
103: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
104: x_dequeue_options.navigation := wf_event.navigation ;
105: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,
106: dequeue_options => x_dequeue_options,
107: message_properties => x_message_properties, /* OUT */

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

101: -- if wf_dequeue is called indivudiually, we should return the event.
102: -- because the consumer doesn't know the navigation_option.
103: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
104: x_dequeue_options.navigation := wf_event.navigation ;
105: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,
106: dequeue_options => x_dequeue_options,
107: message_properties => x_message_properties, /* OUT */
108: payload => p_event, /* OUT */
109: msgid => x_msgid); /* OUT */

Line 113: wf_event.navigation := dbms_aq.next_message;

109: msgid => x_msgid); /* OUT */
110:
111:
112: --Now set the navigation to next message
113: wf_event.navigation := dbms_aq.next_message;
114: end if;
115: when others then
116: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
117: raise;

Line 116: wf_event.navigation := dbms_aq.FIRST_MESSAGE;

112: --Now set the navigation to next message
113: wf_event.navigation := dbms_aq.next_message;
114: end if;
115: when others then
116: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
117: raise;
118: END;
119:
120: -- Set the Receive Date

Line 143: x_enqueue_options dbms_aq.enqueue_options_t;

139: x_to_agent_name varchar2(30);
140: x_to_system_name varchar2(30);
141: x_out_queue varchar2(80);
142: x_to_queue varchar2(80);
143: x_enqueue_options dbms_aq.enqueue_options_t;
144: x_message_properties dbms_aq.message_properties_t;
145: x_msgid RAW(16);
146: x_name varchar2(30);
147: x_address varchar2(1024);

Line 144: x_message_properties dbms_aq.message_properties_t;

140: x_to_system_name varchar2(30);
141: x_out_queue varchar2(80);
142: x_to_queue varchar2(80);
143: x_enqueue_options dbms_aq.enqueue_options_t;
144: x_message_properties dbms_aq.message_properties_t;
145: x_msgid RAW(16);
146: x_name varchar2(30);
147: x_address varchar2(1024);
148: x_protocol varchar2(30);

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

266: end if;
267: END IF;
268: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
269: wf_log_pkg.string(wf_log_pkg.level_statement,
270: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
271: 'calling dbms_aq.enqueue');
272: end if;
273:
274: DBMS_AQ.ENQUEUE(

Line 271: 'calling dbms_aq.enqueue');

267: END IF;
268: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
269: wf_log_pkg.string(wf_log_pkg.level_statement,
270: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
271: 'calling dbms_aq.enqueue');
272: end if;
273:
274: DBMS_AQ.ENQUEUE(
275: queue_name => x_out_queue,

Line 274: DBMS_AQ.ENQUEUE(

270: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
271: 'calling dbms_aq.enqueue');
272: end if;
273:
274: DBMS_AQ.ENQUEUE(
275: queue_name => x_out_queue,
276: enqueue_options => x_enqueue_options,
277: message_properties => x_message_properties,
278: payload => p_event,

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

283:
284: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
285: wf_log_pkg.string(wf_log_pkg.level_procedure,
286: 'wf.plsql.WF_EVENT_QH.enqueue.End',
287: 'finished calling dbms_aq.enqueue');
288: end if;
289:
290: exception
291: when others then