APPS.JTF_IH_BULK dependencies on DBMS_AQ

Line 118: deq_options dbms_aq.dequeue_options_t;

114: errbuf OUT NOCOPY VARCHAR2,
115: retcode OUT NOCOPY VARCHAR2
116: ) IS
117:
118: deq_options dbms_aq.dequeue_options_t;
119: deq_del_option dbms_aq.dequeue_options_t;
120: msg_props dbms_aq.message_properties_t;
121: bulk_obj system.ih_bulk_type;
122: l_dummy_payload system.ih_bulk_type;

Line 119: deq_del_option dbms_aq.dequeue_options_t;

115: retcode OUT NOCOPY VARCHAR2
116: ) IS
117:
118: deq_options dbms_aq.dequeue_options_t;
119: deq_del_option dbms_aq.dequeue_options_t;
120: msg_props dbms_aq.message_properties_t;
121: bulk_obj system.ih_bulk_type;
122: l_dummy_payload system.ih_bulk_type;
123: l_dummy_msg_id RAW(16);

Line 120: msg_props dbms_aq.message_properties_t;

116: ) IS
117:
118: deq_options dbms_aq.dequeue_options_t;
119: deq_del_option dbms_aq.dequeue_options_t;
120: msg_props dbms_aq.message_properties_t;
121: bulk_obj system.ih_bulk_type;
122: l_dummy_payload system.ih_bulk_type;
123: l_dummy_msg_id RAW(16);
124: l_msg_id RAW(16);

Line 259: deq_options.dequeue_mode := dbms_aq.LOCKED;

255:
256: -- dequeue options
257: -- dequeue mode shall be LOCKED for now, the data will get deleted after
258: -- saving in RECOVERY table
259: deq_options.dequeue_mode := dbms_aq.LOCKED;
260: deq_options.navigation := dbms_aq.NEXT_MESSAGE;
261: deq_options.wait := dbms_aq.NO_WAIT;
262:
263: -- these are the options for the second dequeue

Line 260: deq_options.navigation := dbms_aq.NEXT_MESSAGE;

256: -- dequeue options
257: -- dequeue mode shall be LOCKED for now, the data will get deleted after
258: -- saving in RECOVERY table
259: deq_options.dequeue_mode := dbms_aq.LOCKED;
260: deq_options.navigation := dbms_aq.NEXT_MESSAGE;
261: deq_options.wait := dbms_aq.NO_WAIT;
262:
263: -- these are the options for the second dequeue
264: deq_del_option.dequeue_mode := dbms_aq.REMOVE_NODATA;

Line 261: deq_options.wait := dbms_aq.NO_WAIT;

257: -- dequeue mode shall be LOCKED for now, the data will get deleted after
258: -- saving in RECOVERY table
259: deq_options.dequeue_mode := dbms_aq.LOCKED;
260: deq_options.navigation := dbms_aq.NEXT_MESSAGE;
261: deq_options.wait := dbms_aq.NO_WAIT;
262:
263: -- these are the options for the second dequeue
264: deq_del_option.dequeue_mode := dbms_aq.REMOVE_NODATA;
265: deq_del_option.wait := dbms_aq.NO_WAIT;

Line 264: deq_del_option.dequeue_mode := dbms_aq.REMOVE_NODATA;

260: deq_options.navigation := dbms_aq.NEXT_MESSAGE;
261: deq_options.wait := dbms_aq.NO_WAIT;
262:
263: -- these are the options for the second dequeue
264: deq_del_option.dequeue_mode := dbms_aq.REMOVE_NODATA;
265: deq_del_option.wait := dbms_aq.NO_WAIT;
266:
267: num_rec := 0;
268:

Line 265: deq_del_option.wait := dbms_aq.NO_WAIT;

261: deq_options.wait := dbms_aq.NO_WAIT;
262:
263: -- these are the options for the second dequeue
264: deq_del_option.dequeue_mode := dbms_aq.REMOVE_NODATA;
265: deq_del_option.wait := dbms_aq.NO_WAIT;
266:
267: num_rec := 0;
268:
269: --LOOP

Line 279: DBMS_AQ.DEQUEUE (

275: -- this is being done so that the exception handler way down below can
276: -- log any bulk requests that are fetched but not processed
277: l_msg_id := null;
278:
279: DBMS_AQ.DEQUEUE (
280: queue_name => 'JTF_IH_BULK_Q',
281: dequeue_options => deq_options,
282: message_properties => msg_props,
283: payload => bulk_obj,

Line 317: DBMS_AQ.DEQUEUE (

313:
314: -- Now delete the row from AQ
315: deq_del_option.msgid := l_msg_id;
316:
317: DBMS_AQ.DEQUEUE (
318: queue_name => 'JTF_IH_BULK_Q',
319: dequeue_options => deq_del_option,
320: message_properties => msg_props,
321: payload => l_dummy_payload,

Line 345: DBMS_AQ.DEQUEUE (

341:
342: -- Now delete row from AQ
343: deq_del_option.msgid := l_msg_id;
344:
345: DBMS_AQ.DEQUEUE (
346: queue_name => 'JTF_IH_BULK_Q',
347: dequeue_options => deq_del_option,
348: message_properties => msg_props,
349: payload => l_dummy_payload,