33: pAttrList IN VARCHAR2,
34: pCorrelation IN VARCHAR2, pErrorStack IN VARCHAR2)
35: AS
36: BEGIN
37: WF_QUEUE.EnqueueInbound(pItemType, pItemKey, pActID, pResult,
38: pAttrList, pCorrelation, pErrorStack);
39: EXCEPTION
40: WHEN OTHERS THEN
41: raise;
73: lMessage_properties dbms_aq.message_properties_t;
74:
75: BEGIN
76:
77: wf_queue.set_queue_names;
78:
79: if pCorrelation is not null then
80: lCorrelation := pCorrelation;
81: else
78:
79: if pCorrelation is not null then
80: lCorrelation := pCorrelation;
81: else
82: lCorrelation := wf_queue.account_name||nvl(pItemType,'%');
83: end if;
84: lDequeue_options.correlation := lCorrelation;
85: lDequeue_options.dequeue_mode := pDequeueMode;
86: lDequeue_options.wait := wfj_queue.dequeueDelay;
88:
89: lMessageHandle := hextoraw(pMessageHandle);
90: dbms_aq.dequeue
91: (
92: queue_name => wf_queue.OutboundQueue,
93: dequeue_options => lDequeue_options,
94: message_properties => lMessage_properties,
95: payload => lPayLoad,
96: msgid => lMessageHandle