DBA Data[Home] [Help]

APPS.JTF_PF_CONV_PKG dependencies on DBMS_AQ

Line 34: enqueue_options dbms_aq.enqueue_options_t;

30: last_migrate_day DATE;
31:
32: PROCEDURE writePFObjectTable(objTab JTF_PF_PAGE_OBJECT_TABLE, write_to_jtf INTEGER, tech_stack_tbl JTF_PF_TECHSTACK_TABLE, track_prps_tbl JTF_PF_TRACKPURPOSE_TABLE, dbdate OUT NOCOPY DATE) IS
33: PRAGMA AUTONOMOUS_TRANSACTION;
34: enqueue_options dbms_aq.enqueue_options_t;
35: message_properties dbms_aq.message_properties_t;
36: message_handle RAW(16);
37: objTabLocal JTF_PF_PAGE_OBJECT_TABLE;
38: obj JTF_PF_PAGE_OBJECT;

Line 35: message_properties dbms_aq.message_properties_t;

31:
32: PROCEDURE writePFObjectTable(objTab JTF_PF_PAGE_OBJECT_TABLE, write_to_jtf INTEGER, tech_stack_tbl JTF_PF_TECHSTACK_TABLE, track_prps_tbl JTF_PF_TRACKPURPOSE_TABLE, dbdate OUT NOCOPY DATE) IS
33: PRAGMA AUTONOMOUS_TRANSACTION;
34: enqueue_options dbms_aq.enqueue_options_t;
35: message_properties dbms_aq.message_properties_t;
36: message_handle RAW(16);
37: objTabLocal JTF_PF_PAGE_OBJECT_TABLE;
38: obj JTF_PF_PAGE_OBJECT;
39: dummyPageObj JTF_PF_PAGE_OBJECT;

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

61:
62: ELSE
63: message_properties.correlation := seq_num;
64: message_properties.expiration := 24*60*60; -- messages expire in one day after first dequeue
65: dbms_aq.enqueue(queue_name => qname,
66: enqueue_options => enqueue_options,
67: message_properties => message_properties,
68: payload => dummyPageObj,
69: msgid => message_handle);

Line 83: enqueue_options dbms_aq.enqueue_options_t;

79: ============================================================================================================*/
80: PROCEDURE writePFObject(obj JTF_PF_PAGE_OBJECT,write_to_jtf INTEGER,tech_stack VARCHAR2, track_purpose VARCHAR2, dbdate OUT NOCOPY DATE) IS
81: PRAGMA AUTONOMOUS_TRANSACTION;
82: pObject JTF_PF_PAGE_OBJECT;
83: enqueue_options dbms_aq.enqueue_options_t;
84: message_properties dbms_aq.message_properties_t;
85: message_handle RAW(16);
86: dummyPageObj JTF_PF_PAGE_OBJECT;
87: seq_num INTEGER;

Line 84: message_properties dbms_aq.message_properties_t;

80: PROCEDURE writePFObject(obj JTF_PF_PAGE_OBJECT,write_to_jtf INTEGER,tech_stack VARCHAR2, track_purpose VARCHAR2, dbdate OUT NOCOPY DATE) IS
81: PRAGMA AUTONOMOUS_TRANSACTION;
82: pObject JTF_PF_PAGE_OBJECT;
83: enqueue_options dbms_aq.enqueue_options_t;
84: message_properties dbms_aq.message_properties_t;
85: message_handle RAW(16);
86: dummyPageObj JTF_PF_PAGE_OBJECT;
87: seq_num INTEGER;
88: BEGIN

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

99: VALUES (dummyPageObj, 0, 690, obj.info.Day, 690, obj.info.Timestamp, tech_stack, track_purpose);
100: ELSE
101: message_properties.correlation := seq_num;
102: message_properties.expiration := 24*60*60; -- messages expire in one day after first dequeue
103: dbms_aq.enqueue(queue_name => qname,
104: enqueue_options => enqueue_options,
105: message_properties => message_properties,
106: payload => dummyPageObj,
107: msgid => message_handle);

Line 242: dopt dbms_aq.dequeue_options_t;

238:
239: PROCEDURE uploadAllNewPfObjects IS --ang This proc is currently not being invoked anywhere
240: pgObjects JTF_PF_PAGE_OBJECT ;
241: new_messages BOOLEAN :=TRUE;
242: dopt dbms_aq.dequeue_options_t;
243: mprop dbms_aq.message_properties_t;
244: deq_msgid RAW(16);
245: no_messages EXCEPTION;
246: last_msg_in_jtf_rep INTEGER;

Line 243: mprop dbms_aq.message_properties_t;

239: PROCEDURE uploadAllNewPfObjects IS --ang This proc is currently not being invoked anywhere
240: pgObjects JTF_PF_PAGE_OBJECT ;
241: new_messages BOOLEAN :=TRUE;
242: dopt dbms_aq.dequeue_options_t;
243: mprop dbms_aq.message_properties_t;
244: deq_msgid RAW(16);
245: no_messages EXCEPTION;
246: last_msg_in_jtf_rep INTEGER;
247: last_msg_to_upload INTEGER;

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

254: -- select max(a.corrid) into last_msg_to_upload from JTF_PF_LOGGING_TABLE a;
255:
256: IF last_msg_in_jtf_rep IS NOT NULL THEN current_msg := last_msg_in_jtf_rep; END IF;
257:
258: dopt.navigation:=dbms_aq.first_message;
259: dopt.dequeue_mode := DBMS_AQ.BROWSE;
260: dopt.wait := 0;
261: WHILE (new_messages) LOOP
262: BEGIN

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

255:
256: IF last_msg_in_jtf_rep IS NOT NULL THEN current_msg := last_msg_in_jtf_rep; END IF;
257:
258: dopt.navigation:=dbms_aq.first_message;
259: dopt.dequeue_mode := DBMS_AQ.BROWSE;
260: dopt.wait := 0;
261: WHILE (new_messages) LOOP
262: BEGIN
263: IF(current_msg IS NOT NULL) THEN

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

265: IF (current_msg > last_msg_to_upload) THEN new_messages := FALSE; END IF;
266: dopt.correlation := current_msg;
267: END IF;
268:
269: dbms_aq.dequeue(queue_name=>qname,
270: dequeue_options=>dopt,
271: message_properties=> mprop,
272: payload => pgObjects,
273: msgid => deq_msgid);

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

272: payload => pgObjects,
273: msgid => deq_msgid);
274:
275: current_msg := mprop.correlation;
276: dopt.navigation := dbms_aq.first_message;
277: dopt.wait := 0;
278: INSERT INTO jtf_pf_repository( --ang no need to update this insert as the proc is not in use
279: pageobject, object_version_number,
280: created_by, creation_date,