PACKAGE BODY: APPS.JTF_IH_BULK_Q_PKG

Source

1 PACKAGE BODY JTF_IH_BULK_Q_PKG AS
2 /* $Header: JTFIHPQB.pls 115.3 2004/01/30 16:17:31 msista noship $ */
3 
4 -- -------------------------------------------------------------
5 PROCEDURE CLOBENQUEUE(p_bulkWriterCode in  VARCHAR2,
6                                         p_bulkBatchType  in  VARCHAR2,
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);
16 
17 
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');
27     dbms_aq.enqueue('JTF_IH_BULK_Q', enqopt, msgprop, enq_userdata, enq_msgid);
28 
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;
38   l_amount           number;
39   n_amount           number;
40   buffer             raw(4096);
41   xmlfile            VARCHAR2(32767);
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;
51 END JTF_IH_BULK_Q_PKG;