[Home] [Help]
83: procedure Process_Inbound_Event(itemtype in varchar2,
84: itemkey in varchar2,
85: actid in number,
86: message_handle in raw,
87: p_payload in out nocopy system.wf_payload_t)
88: as
89: colon number;
90: status varchar2(30);
91:
291: procedure PurgeEvent(queuename in varchar2,
292: message_handle in raw,
293: multiconsumer in boolean default FALSE) as
294:
295: event system.wf_payload_t;
296: dequeue_options dbms_aq.dequeue_options_t;
297: message_properties dbms_aq.message_properties_t;
298: msg_id raw(16);
299: begin
343: procedure PurgeItemtype(queuename in varchar2,
344: itemtype in varchar2 default null,
345: correlation in varchar2 default null )
346: as
347: event system.wf_payload_t;
348: dequeue_options dbms_aq.dequeue_options_t;
349: message_properties dbms_aq.message_properties_t;
350: msg_id raw(16);
351:
613: dequeuemode in number,
614: navigation in number default 1,
615: correlation in varchar2 default null,
616: itemtype in varchar2 default null,
617: payload out NOCOPY system.wf_payload_t,
618: message_handle in out NOCOPY raw,
619: timeout out NOCOPY boolean)
620:
621: as
663: param_list out NOCOPY varchar2,
664: message_handle in out NOCOPY raw,
665: timeout out NOCOPY boolean)
666: as
667: event system.wf_payload_t;
668: lcorrelation varchar2(80);
669: begin
670: wf_queue.set_queue_names;
671:
716: procedure Dequeue_Event(queuename in varchar2,
717: dequeuemode in number,
718: navigation in number default 1,
719: correlation in varchar2 default null,
720: payload out NOCOPY system.wf_payload_t,
721: message_handle in out NOCOPY raw,
722: timeout out NOCOPY boolean,
723: multiconsumer in boolean default FALSE)
724: as
808: -- message_handle of event in the deferred queue
809: -- maxthreshold - the threshold level
810: -- minthreshold
811: --
812: function activity_valid (event in system.wf_payload_t,
813: message_handle in raw,
814: maxthreshold in number default null,
815: minthreshold in number default null)
816: return BOOLEAN is
905: message_handle in out NOCOPY raw,
906: priority in number default null)
907:
908: as
909: event system.wf_payload_t;
910: enqueue_options dbms_aq.enqueue_options_t;
911: message_properties dbms_aq.message_properties_t;
912: l_increment_delay number;
913: l_min_delay number;
987: end if;
988:
989: wf_queue.set_queue_names;
990: -- construct the event object
991: event:=system.wf_payload_t(itemtype,itemkey,actid,funcname,paramlist,result);
992:
993: -- dont make the data visible on the queue until a commit is issued
994: -- this way queue data and normal table data (wf statuses) are in synch.
995: enqueue_options.visibility := DBMS_AQ.ON_COMMIT;
1062: procedure ProcessInboundQueue (itemtype in varchar2 default null,
1063: correlation in varchar2 default null)
1064: as
1065:
1066: payload system.wf_payload_t;
1067: navigation varchar2(10);
1068: timeout boolean:= FALSE;
1069: cursor_name number;
1070: row_processed integer;
1165: maxthreshold in number default null,
1166: correlation in varchar2 default null)
1167:
1168: as
1169: payload system.wf_payload_t;
1170: timeout boolean:= FALSE;
1171: navigation varchar2(10);
1172: row_processed integer;
1173: message_handle raw(16);
1311: actid in number,
1312: correlation in varchar2 default null,
1313: multiconsumer in boolean default FALSE) return raw
1314: is
1315: event system.wf_payload_t;
1316: dequeue_options dbms_aq.dequeue_options_t;
1317: message_properties dbms_aq.message_properties_t;
1318: msg_id raw(16);
1319: begin