DBA Data[Home] [Help]

APPS.WF_ERROR_QH dependencies on DBMS_AQ

Line 9: x_dequeue_options dbms_aq.dequeue_options_t;

5: 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: no_messages exception;
13: pragma exception_init (no_messages, -25228);

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: no_messages exception;
13: pragma exception_init (no_messages, -25228);
14:

Line 56: --x_dequeue_options.wait := DBMS_AQ.NO_WAIT;

52: end if;
53: end if;
54:
55: x_dequeue_options.consumer_name := x_agent_name;
56: --x_dequeue_options.wait := DBMS_AQ.NO_WAIT;
57: x_dequeue_options.navigation := wf_event.navigation;
58: x_dequeue_options.wait := 1;
59: BEGIN
60: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,

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

56: --x_dequeue_options.wait := DBMS_AQ.NO_WAIT;
57: x_dequeue_options.navigation := wf_event.navigation;
58: x_dequeue_options.wait := 1;
59: BEGIN
60: DBMS_AQ.DEQUEUE(queue_name => x_queue_name,
61: dequeue_options => x_dequeue_options,
62: message_properties => x_message_properties, /* OUT */
63: payload => p_event, /* OUT */
64: msgid => x_msgid); /* OUT */

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

61: dequeue_options => x_dequeue_options,
62: message_properties => x_message_properties, /* OUT */
63: payload => p_event, /* OUT */
64: msgid => x_msgid); /* OUT */
65: wf_event.navigation := dbms_aq.next_message;
66: EXCEPTION
67: when no_messages then
68:
69: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then

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

71: 'wf.plsql.WF_ERROR_QH.dequeue.queue_empty',
72: 'No more messages in dequeue.');
73: end if;
74:
75: wf_event.navigation := dbms_aq.first_message;
76: p_event := NULL;
77: return;
78: --Capture the snapshot too old error
79: when snap_too_old then

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

79: when snap_too_old then
80: --Workaround for AQ when receiving ORA-01555 using NEXT_MESSAGE as
81: --navigation. We will try to set to FIRST_MESSAGE and dequeue to
82: --silently handle this exception.
83: if (wf_event.navigation = dbms_aq.FIRST_MESSAGE) then
84: raise;
85: else
86: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
87: x_dequeue_options.navigation := wf_event.navigation;

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

82: --silently handle this exception.
83: if (wf_event.navigation = dbms_aq.FIRST_MESSAGE) then
84: raise;
85: else
86: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
87: x_dequeue_options.navigation := wf_event.navigation;
88: dbms_aq.dequeue(queue_name => x_queue_name,
89: dequeue_options => x_dequeue_options,
90: message_properties => x_message_properties, -- out

Line 88: dbms_aq.dequeue(queue_name => x_queue_name,

84: raise;
85: else
86: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
87: x_dequeue_options.navigation := wf_event.navigation;
88: dbms_aq.dequeue(queue_name => x_queue_name,
89: dequeue_options => x_dequeue_options,
90: message_properties => x_message_properties, -- out
91: payload => p_event, -- out
92: msgid => x_msgid); -- out

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

91: payload => p_event, -- out
92: msgid => x_msgid); -- out
93:
94: --Set the navigation now to the next message
95: wf_event.navigation := dbms_aq.next_message;
96: end if;
97: when others then
98: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
99: raise;

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

94: --Set the navigation now to the next message
95: wf_event.navigation := dbms_aq.next_message;
96: end if;
97: when others then
98: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
99: raise;
100: END;
101: exception
102: when others then

Line 125: x_enqueue_options dbms_aq.enqueue_options_t;

121: is
122: x_out_agent_name varchar2(30);
123: x_out_system_name varchar2(30);
124: x_out_queue varchar2(80);
125: x_enqueue_options dbms_aq.enqueue_options_t;
126: x_message_properties dbms_aq.message_properties_t;
127: x_msgid RAW(16);
128: x_name varchar2(30);
129: x_address varchar2(1024);

Line 126: x_message_properties dbms_aq.message_properties_t;

122: x_out_agent_name varchar2(30);
123: x_out_system_name varchar2(30);
124: x_out_queue varchar2(80);
125: x_enqueue_options dbms_aq.enqueue_options_t;
126: x_message_properties dbms_aq.message_properties_t;
127: x_msgid RAW(16);
128: x_name varchar2(30);
129: x_address varchar2(1024);
130: x_protocol varchar2(30);

Line 176: 'calling dbms_aq.enqueue');

172:
173: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
174: wf_log_pkg.string(wf_log_pkg.level_statement,
175: 'wf.plsql.WF_ERROR_QH.enqueue.dbms_qa',
176: 'calling dbms_aq.enqueue');
177: end if;
178:
179: DBMS_AQ.ENQUEUE(
180: queue_name => x_out_queue,

Line 179: DBMS_AQ.ENQUEUE(

175: 'wf.plsql.WF_ERROR_QH.enqueue.dbms_qa',
176: 'calling dbms_aq.enqueue');
177: end if;
178:
179: DBMS_AQ.ENQUEUE(
180: queue_name => x_out_queue,
181: enqueue_options => x_enqueue_options,
182: message_properties => x_message_properties,
183: payload => p_event,

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

185:
186: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
187: wf_log_pkg.string(wf_log_pkg.level_statement,
188: 'wf.plsql.WF_ERROR_QH.enqueue.done',
189: 'finished calling dbms_aq.enqueue');
190: end if;
191:
192: exception
193: when others then