APPS.JTF_PF_CONV_PKG dependencies on DBMS_AQ

Line 40: enqueue_options dbms_aq.enqueue_options_t;

36: track_prps_tbl JTF_PF_TRACKPURPOSE_TABLE,
37: dbdate OUT NOCOPY DATE)
38: IS
39: PRAGMA AUTONOMOUS_TRANSACTION;
40: enqueue_options dbms_aq.enqueue_options_t;
41: message_properties dbms_aq.message_properties_t;
42: message_handle RAW(16);
43: objTabLocal JTF_PF_PAGE_OBJECT_TABLE;
44: obj JTF_PF_PAGE_OBJECT;

Line 41: message_properties dbms_aq.message_properties_t;

37: dbdate OUT NOCOPY DATE)
38: IS
39: PRAGMA AUTONOMOUS_TRANSACTION;
40: enqueue_options dbms_aq.enqueue_options_t;
41: message_properties dbms_aq.message_properties_t;
42: message_handle RAW(16);
43: objTabLocal JTF_PF_PAGE_OBJECT_TABLE;
44: obj JTF_PF_PAGE_OBJECT;
45: dummyPageObj JTF_PF_PAGE_OBJECT;

Line 90: dbms_aq.enqueue(queue_name => qname,

86: ELSE
87: message_properties.correlation := seq_num;
88: message_properties.expiration := 24*60*60; -- messages expire in one day
89: -- after first dequeue
90: dbms_aq.enqueue(queue_name => qname,
91: enqueue_options => enqueue_options,
92: message_properties => message_properties,
93: payload => dummyPageObj,
94: msgid => message_handle);

Line 115: enqueue_options dbms_aq.enqueue_options_t;

111: dbdate OUT NOCOPY DATE)
112: IS
113: PRAGMA AUTONOMOUS_TRANSACTION;
114: pObject JTF_PF_PAGE_OBJECT;
115: enqueue_options dbms_aq.enqueue_options_t;
116: message_properties dbms_aq.message_properties_t;
117: message_handle RAW(16);
118: dummyPageObj JTF_PF_PAGE_OBJECT;
119: seq_num INTEGER;

Line 116: message_properties dbms_aq.message_properties_t;

112: IS
113: PRAGMA AUTONOMOUS_TRANSACTION;
114: pObject JTF_PF_PAGE_OBJECT;
115: enqueue_options dbms_aq.enqueue_options_t;
116: message_properties dbms_aq.message_properties_t;
117: message_handle RAW(16);
118: dummyPageObj JTF_PF_PAGE_OBJECT;
119: seq_num INTEGER;
120: enable_site varchar2(10) := NULL;

Line 155: dbms_aq.enqueue(queue_name => qname,

151: ELSE
152: message_properties.correlation := seq_num;
153: message_properties.expiration := 24*60*60; -- messages expire in one day
154: -- after first dequeue
155: dbms_aq.enqueue(queue_name => qname,
156: enqueue_options => enqueue_options,
157: message_properties => message_properties,
158: payload => dummyPageObj,
159: msgid => message_handle);

Line 305: dopt dbms_aq.dequeue_options_t;

301: PROCEDURE uploadAllNewPfObjects --ang This proc is currently not being invoked
302: IS --anywhere
303: pgObjects JTF_PF_PAGE_OBJECT ;
304: new_messages BOOLEAN :=TRUE;
305: dopt dbms_aq.dequeue_options_t;
306: mprop dbms_aq.message_properties_t;
307: deq_msgid RAW(16);
308: no_messages EXCEPTION;
309: last_msg_in_jtf_rep INTEGER;

Line 306: mprop dbms_aq.message_properties_t;

302: IS --anywhere
303: pgObjects JTF_PF_PAGE_OBJECT ;
304: new_messages BOOLEAN :=TRUE;
305: dopt dbms_aq.dequeue_options_t;
306: mprop dbms_aq.message_properties_t;
307: deq_msgid RAW(16);
308: no_messages EXCEPTION;
309: last_msg_in_jtf_rep INTEGER;
310: last_msg_to_upload INTEGER;

Line 329: dopt.navigation := dbms_aq.first_message;

325: IF last_msg_in_jtf_rep IS NOT NULL THEN
326: current_msg := last_msg_in_jtf_rep;
327: END IF;
328:
329: dopt.navigation := dbms_aq.first_message;
330: dopt.dequeue_mode := DBMS_AQ.BROWSE;
331: dopt.wait := 0;
332:
333: WHILE (new_messages) LOOP

Line 330: dopt.dequeue_mode := DBMS_AQ.BROWSE;

326: current_msg := last_msg_in_jtf_rep;
327: END IF;
328:
329: dopt.navigation := dbms_aq.first_message;
330: dopt.dequeue_mode := DBMS_AQ.BROWSE;
331: dopt.wait := 0;
332:
333: WHILE (new_messages) LOOP
334: BEGIN

Line 343: dbms_aq.dequeue(queue_name => qname,

339: END IF;
340: dopt.correlation := current_msg;
341: END IF;
342:
343: dbms_aq.dequeue(queue_name => qname,
344: dequeue_options => dopt,
345: message_properties => mprop,
346: payload => pgObjects,
347: msgid => deq_msgid);

Line 350: dopt.navigation := dbms_aq.first_message;

346: payload => pgObjects,
347: msgid => deq_msgid);
348:
349: current_msg := mprop.correlation;
350: dopt.navigation := dbms_aq.first_message;
351: dopt.wait := 0;
352:
353: INSERT INTO jtf_pf_repository( --ang no need to update this insert
354: pageobject, --as the proc is not in use