APPS.JTF_IH_BULK_Q_PKG dependencies on DBMS_AQ

Line 11: enqopt dbms_aq.enqueue_options_t;

7: p_bulkBatchId in NUMBER,
8: p_bulkInteractionId in NUMBER,
9: enq_msgid out NOCOPY RAW) as
10: enq_userdata system.IH_BULK_TYPE;
11: enqopt dbms_aq.enqueue_options_t;
12: msgprop dbms_aq.message_properties_t;
13:
14: queue_disabled_exception exception;
15: pragma exception_init(queue_disabled_exception,-25207);

Line 12: msgprop dbms_aq.message_properties_t;

8: p_bulkInteractionId in NUMBER,
9: enq_msgid out NOCOPY RAW) as
10: enq_userdata system.IH_BULK_TYPE;
11: enqopt dbms_aq.enqueue_options_t;
12: msgprop dbms_aq.message_properties_t;
13:
14: queue_disabled_exception exception;
15: pragma exception_init(queue_disabled_exception,-25207);
16:

Line 22: dbms_aq.enqueue('JTF_IH_BULK_Q', enqopt, msgprop, enq_userdata, enq_msgid);

18:
19: BEGIN
20:
21: enq_userdata := system.IH_BULK_TYPE(p_bulkWriterCode, p_bulkBatchType, p_bulkBatchId, p_bulkInteractionId, empty_clob());
22: dbms_aq.enqueue('JTF_IH_BULK_Q', enqopt, msgprop, enq_userdata, enq_msgid);
23:
24: EXCEPTION
25: WHEN queue_disabled_exception THEN
26: dbms_aqadm.start_queue('JTF_IH_BULK_Q');

Line 26: dbms_aqadm.start_queue('JTF_IH_BULK_Q');

22: dbms_aq.enqueue('JTF_IH_BULK_Q', enqopt, msgprop, enq_userdata, enq_msgid);
23:
24: EXCEPTION
25: WHEN queue_disabled_exception THEN
26: dbms_aqadm.start_queue('JTF_IH_BULK_Q');
27: dbms_aq.enqueue('JTF_IH_BULK_Q', enqopt, msgprop, enq_userdata, enq_msgid);
28:
29: END CLOBENQUEUE;
30:

Line 27: dbms_aq.enqueue('JTF_IH_BULK_Q', enqopt, msgprop, enq_userdata, enq_msgid);

23:
24: EXCEPTION
25: WHEN queue_disabled_exception THEN
26: dbms_aqadm.start_queue('JTF_IH_BULK_Q');
27: dbms_aq.enqueue('JTF_IH_BULK_Q', enqopt, msgprop, enq_userdata, enq_msgid);
28:
29: END CLOBENQUEUE;
30:
31: PROCEDURE CLOBDEQUEUE AS

Line 33: dequeue_options dbms_aq.dequeue_options_t;

29: END CLOBENQUEUE;
30:
31: PROCEDURE CLOBDEQUEUE AS
32:
33: dequeue_options dbms_aq.dequeue_options_t;
34: message_properties dbms_aq.message_properties_t;
35: mid raw(16);
36: pload system.IH_BULK_TYPE;
37: lob_loc clob;

Line 34: message_properties dbms_aq.message_properties_t;

30:
31: PROCEDURE CLOBDEQUEUE AS
32:
33: dequeue_options dbms_aq.dequeue_options_t;
34: message_properties dbms_aq.message_properties_t;
35: mid raw(16);
36: pload system.IH_BULK_TYPE;
37: lob_loc clob;
38: l_amount number;

Line 46: dbms_aq.dequeue('JTF_IH_BULK_Q', dequeue_options, message_properties, pload, mid);

42:
43: BEGIN
44:
45:
46: dbms_aq.dequeue('JTF_IH_BULK_Q', dequeue_options, message_properties, pload, mid);
47:
48: commit;
49:
50: END CLOBDEQUEUE;