APPS.ARP_QUEUE dependencies on DBMS_AQ

Line 4: g_nq_opts DBMS_AQ.ENQUEUE_OPTIONS_T;

1: PACKAGE BODY arp_queue AS
2: -- $Header: ARPQUEFB.pls 115.9 2003/10/10 14:25:45 mraymond ship $
3:
4: g_nq_opts DBMS_AQ.ENQUEUE_OPTIONS_T;
5: g_dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
6: g_recipients DBMS_AQ.AQ$_RECIPIENT_LIST_T;
7: g_msg_id RAW(16);
8: g_full_qname VARCHAR2(61);

Line 5: g_dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;

1: PACKAGE BODY arp_queue AS
2: -- $Header: ARPQUEFB.pls 115.9 2003/10/10 14:25:45 mraymond ship $
3:
4: g_nq_opts DBMS_AQ.ENQUEUE_OPTIONS_T;
5: g_dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
6: g_recipients DBMS_AQ.AQ$_RECIPIENT_LIST_T;
7: g_msg_id RAW(16);
8: g_full_qname VARCHAR2(61);
9:

Line 6: g_recipients DBMS_AQ.AQ$_RECIPIENT_LIST_T;

2: -- $Header: ARPQUEFB.pls 115.9 2003/10/10 14:25:45 mraymond ship $
3:
4: g_nq_opts DBMS_AQ.ENQUEUE_OPTIONS_T;
5: g_dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
6: g_recipients DBMS_AQ.AQ$_RECIPIENT_LIST_T;
7: g_msg_id RAW(16);
8: g_full_qname VARCHAR2(61);
9:
10: l_no_more_msgs EXCEPTION;

Line 23: l_msg_prop DBMS_AQ.MESSAGE_PROPERTIES_T;

19: PROCEDURE enqueue (p_msg IN system.AR_REV_REC_TYP) AS
20:
21: trx_with_no_rules EXCEPTION;
22: l_msg system.AR_REV_REC_TYP := p_msg;
23: l_msg_prop DBMS_AQ.MESSAGE_PROPERTIES_T;
24:
25: BEGIN
26:
27: --

Line 40: DBMS_AQ.ENQUEUE(

36: p_msg.customer_trx_id || '> Created From : <' || p_msg.created_from || ' ' ||p_msg.org_id );
37: END IF;
38:
39: -- Enqueue it with the default options.
40: DBMS_AQ.ENQUEUE(
41: queue_name => get_full_qname('AR_REV_REC_Q'),
42: enqueue_options => g_nq_opts,
43: message_properties => l_msg_prop,
44: payload => l_msg,

Line 63: p_wait IN INTEGER := DBMS_AQ.NO_WAIT,

59: +=========================================================================*/
60:
61: PROCEDURE dequeue (p_msg IN OUT NOCOPY system.AR_REV_REC_TYP,
62: p_browse IN BOOLEAN := FALSE,
63: p_wait IN INTEGER := DBMS_AQ.NO_WAIT,
64: p_first IN BOOLEAN := FALSE) AS
65:
66: l_msg_prop DBMS_AQ.MESSAGE_PROPERTIES_T;
67:

Line 66: l_msg_prop DBMS_AQ.MESSAGE_PROPERTIES_T;

62: p_browse IN BOOLEAN := FALSE,
63: p_wait IN INTEGER := DBMS_AQ.NO_WAIT,
64: p_first IN BOOLEAN := FALSE) AS
65:
66: l_msg_prop DBMS_AQ.MESSAGE_PROPERTIES_T;
67:
68: l_no_more_msgs EXCEPTION;
69: PRAGMA EXCEPTION_INIT(l_no_more_msgs, -25228);
70:

Line 79: g_dq_opts.dequeue_mode := DBMS_AQ.BROWSE;

75: arp_util.print_fcn_label('arp_queue.dequeue()+');
76: --
77:
78: IF p_browse THEN
79: g_dq_opts.dequeue_mode := DBMS_AQ.BROWSE;
80: ELSE
81: g_dq_opts.dequeue_mode := DBMS_AQ.REMOVE;
82: END IF;
83:

Line 81: g_dq_opts.dequeue_mode := DBMS_AQ.REMOVE;

77:
78: IF p_browse THEN
79: g_dq_opts.dequeue_mode := DBMS_AQ.BROWSE;
80: ELSE
81: g_dq_opts.dequeue_mode := DBMS_AQ.REMOVE;
82: END IF;
83:
84: IF p_first THEN
85: g_dq_opts.navigation := DBMS_AQ.FIRST_MESSAGE; --- Get the First available message

Line 85: g_dq_opts.navigation := DBMS_AQ.FIRST_MESSAGE; --- Get the First available message

81: g_dq_opts.dequeue_mode := DBMS_AQ.REMOVE;
82: END IF;
83:
84: IF p_first THEN
85: g_dq_opts.navigation := DBMS_AQ.FIRST_MESSAGE; --- Get the First available message
86: ELSE
87: g_dq_opts.navigation := DBMS_AQ.NEXT_MESSAGE; --- Get the Next available message
88: END IF;
89:

Line 87: g_dq_opts.navigation := DBMS_AQ.NEXT_MESSAGE; --- Get the Next available message

83:
84: IF p_first THEN
85: g_dq_opts.navigation := DBMS_AQ.FIRST_MESSAGE; --- Get the First available message
86: ELSE
87: g_dq_opts.navigation := DBMS_AQ.NEXT_MESSAGE; --- Get the Next available message
88: END IF;
89:
90: g_dq_opts.wait := p_wait;
91: g_dq_opts.consumer_name := consumer_name;

Line 92: g_dq_opts.visibility := DBMS_AQ.IMMEDIATE;

88: END IF;
89:
90: g_dq_opts.wait := p_wait;
91: g_dq_opts.consumer_name := consumer_name;
92: g_dq_opts.visibility := DBMS_AQ.IMMEDIATE;
93: --
94: DBMS_AQ.DEQUEUE(
95: queue_name => get_full_qname('AR_REV_REC_Q'),
96: dequeue_options => g_dq_opts,

Line 94: DBMS_AQ.DEQUEUE(

90: g_dq_opts.wait := p_wait;
91: g_dq_opts.consumer_name := consumer_name;
92: g_dq_opts.visibility := DBMS_AQ.IMMEDIATE;
93: --
94: DBMS_AQ.DEQUEUE(
95: queue_name => get_full_qname('AR_REV_REC_Q'),
96: dequeue_options => g_dq_opts,
97: message_properties => l_msg_prop,
98: payload => p_msg,