APPS.JTF_FM_AQ_WRAPPER_PVT dependencies on DBMS_AQ

Line 19: enqueue_options dbms_aq.enqueue_options_t;

15: priority IN NUMBER,
16: message_handle OUT NOCOPY RAW
17: )
18: IS
19: enqueue_options dbms_aq.enqueue_options_t;
20: message_properties dbms_aq.message_properties_t;
21:
22: BEGIN
23: message_properties.priority := priority;

Line 20: message_properties dbms_aq.message_properties_t;

16: message_handle OUT NOCOPY RAW
17: )
18: IS
19: enqueue_options dbms_aq.enqueue_options_t;
20: message_properties dbms_aq.message_properties_t;
21:
22: BEGIN
23: message_properties.priority := priority;
24:

Line 25: DBMS_AQ.ENQUEUE(queue_name => queue_name,

21:
22: BEGIN
23: message_properties.priority := priority;
24:
25: DBMS_AQ.ENQUEUE(queue_name => queue_name,
26: enqueue_options => enqueue_options,
27: message_properties => message_properties,
28: payload => message_in,
29: msgid => message_handle);

Line 49: dequeue_options DBMS_AQ.dequeue_options_t;

45: message_handle IN RAW,
46: message_out OUT NOCOPY RAW
47: )
48: IS
49: dequeue_options DBMS_AQ.dequeue_options_t;
50: message_properties DBMS_AQ.message_properties_t;
51: message_handle2 RAW(16);
52:
53: BEGIN

Line 50: message_properties DBMS_AQ.message_properties_t;

46: message_out OUT NOCOPY RAW
47: )
48: IS
49: dequeue_options DBMS_AQ.dequeue_options_t;
50: message_properties DBMS_AQ.message_properties_t;
51: message_handle2 RAW(16);
52:
53: BEGIN
54: dequeue_options.wait := waiting_time;

Line 55: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;

51: message_handle2 RAW(16);
52:
53: BEGIN
54: dequeue_options.wait := waiting_time;
55: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;
56: dequeue_options.msgid := message_handle;
57: dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
58:
59: DBMS_AQ.DEQUEUE(queue_name => queue_name,

Line 57: dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;

53: BEGIN
54: dequeue_options.wait := waiting_time;
55: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;
56: dequeue_options.msgid := message_handle;
57: dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
58:
59: DBMS_AQ.DEQUEUE(queue_name => queue_name,
60: dequeue_options => dequeue_options,
61: message_properties => message_properties,

Line 59: DBMS_AQ.DEQUEUE(queue_name => queue_name,

55: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;
56: dequeue_options.msgid := message_handle;
57: dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
58:
59: DBMS_AQ.DEQUEUE(queue_name => queue_name,
60: dequeue_options => dequeue_options,
61: message_properties => message_properties,
62: payload => message_out,
63: msgid => message_handle2);

Line 131: enqueue_options dbms_aq.enqueue_options_t;

127: l_server_id NUMBER;
128: l_queue_name VARCHAR2(50);
129:
130:
131: enqueue_options dbms_aq.enqueue_options_t;
132: message_properties dbms_aq.message_properties_t;
133:
134: BEGIN
135: message_properties.priority := priority;

Line 132: message_properties dbms_aq.message_properties_t;

128: l_queue_name VARCHAR2(50);
129:
130:
131: enqueue_options dbms_aq.enqueue_options_t;
132: message_properties dbms_aq.message_properties_t;
133:
134: BEGIN
135: message_properties.priority := priority;
136:

Line 148: DBMS_AQ.ENQUEUE(queue_name => l_queue_name,

144: CLOSE CQUEUE;
145:
146: IF l_request_status = 'PAUSED' THEN
147:
148: DBMS_AQ.ENQUEUE(queue_name => l_queue_name,
149: enqueue_options => enqueue_options,
150: message_properties => message_properties,
151: payload => message_in,
152: msgid => message_handle);

Line 162: DBMS_AQ.ENQUEUE(queue_name => queue_name,

158: ELSIF l_request_status = 'CANCELED' THEN
159: -- Don't bother to enqueue
160: NULL;
161: ELSE
162: DBMS_AQ.ENQUEUE(queue_name => queue_name,
163: enqueue_options => enqueue_options,
164: message_properties => message_properties,
165: payload => message_in,
166: msgid => message_handle);