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 307: arp_queue.dequeue(p_msg=>l_msg,

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

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

313: arp_standard.debug('No More messages left. Check for any unprocessed Transactions.');
314: END IF;
315: enq_trans;
316: commit;
317: arp_queue.dequeue(p_msg=>l_msg,
318: p_browse=>TRUE,
319: p_first=>TRUE);
320: WHEN OTHERS THEN
321: RAISE;