APPS.ARP_RUN dependencies on ARP_QUEUE

Line 34: arp_queue.enqueue(system.ar_rev_rec_typ(c01_rec.customer_trx_id,

30: arp_util.print_fcn_label('arp_run.enq_trans()+');
31: --
32: FOR c01_rec IN c01 LOOP
33: -- Put the message in the queue
34: arp_queue.enqueue(system.ar_rev_rec_typ(c01_rec.customer_trx_id,
35: NVL(arp_global.sysparam.org_id, 0), 'ARTERRPB', c01_rec.trx_number));
36: --
37: END LOOP;
38: --

Line 94: arp_queue.dequeue(p_msg=>l_msg);

90: LOOP
91:
92: l_dq_success := FALSE;
93:
94: arp_queue.dequeue(p_msg=>l_msg);
95:
96: l_dq_success := TRUE;
97:
98: -- And print it.

Line 197: arp_queue.enqueue(p_msg=>l_msg);

193: IF PG_DEBUG in ('Y', 'C') THEN
194: arp_standard.debug('Putting the last message back in the queue');
195: END IF;
196: --
197: arp_queue.enqueue(p_msg=>l_msg);
198: --
199: commit;
200: --
201: EXCEPTION

Line 308: arp_queue.dequeue(p_msg=>l_msg,

304: --
305: -- Wait for 1 Sec to check for messages
306: --
307: BEGIN
308: arp_queue.dequeue(p_msg=>l_msg,
309: p_browse=>TRUE,
310: p_first=>TRUE);
311: EXCEPTION
312: WHEN g_no_more_msgs THEN

Line 319: arp_queue.dequeue(p_msg=>l_msg,

315: END IF;
316: enq_trans;
317: l_has_enqueue_run := TRUE;
318: commit;
319: arp_queue.dequeue(p_msg=>l_msg,
320: p_browse=>TRUE,
321: p_first=>TRUE);
322: WHEN OTHERS THEN
323: RAISE;