APPS.WF_ENGINE dependencies on WF_QUEUE

Line 3450: wf_queue.ProcessDeferredQueue(itemtype, minthreshold, maxthreshold);

3446: maxthreshold in number) is
3447:
3448:
3449: begin
3450: wf_queue.ProcessDeferredQueue(itemtype, minthreshold, maxthreshold);
3451: exception
3452: when others then
3453: Wf_Core.Context('Wf_Engine', 'ProcessDeferred',itemtype,
3454: to_char(minthreshold), to_char(maxthreshold));

Line 3890: wf_queue.Enablebackgroundqueues;

3886: end if;
3887:
3888: --Bug 2307428
3889: --Enable the deferred and inbound queues.
3890: wf_queue.Enablebackgroundqueues;
3891:
3892: -- Do not need to preserve context
3893: wf_engine.preserved_context := FALSE;
3894:

Line 3898: wf_queue.ProcessInboundQueue(itemtype);

3894:
3895: -- Process deferred activities
3896: if (process_deferred) then
3897: -- process the inbound queue first - it may place events on the deferred Q
3898: wf_queue.ProcessInboundQueue(itemtype);
3899: wf_engine.ProcessDeferred(itemtype, minthreshold, maxthreshold);
3900: end if;
3901:
3902: -- Process timeout activities

Line 5292: wf_queue.enqueue_event

5288: delay :=0;
5289: else
5290: delay := round((act.begin_date - sysdate)*24*60*60 + 0.5);
5291: end if;
5292: wf_queue.enqueue_event
5293: (queuename=>wf_queue.DeferredQueue,
5294: itemtype=> act.item_type,
5295: itemkey=>itemkey,
5296: actid=>act.process_activity,

Line 5293: (queuename=>wf_queue.DeferredQueue,

5289: else
5290: delay := round((act.begin_date - sysdate)*24*60*60 + 0.5);
5291: end if;
5292: wf_queue.enqueue_event
5293: (queuename=>wf_queue.DeferredQueue,
5294: itemtype=> act.item_type,
5295: itemkey=>itemkey,
5296: actid=>act.process_activity,
5297: delay=>delay,

Line 5305: wf_queue.enqueue_event

5301: --msg_id :=null;
5302: elsif act_ftype = 'EXTERNAL' then
5303: -- this is a callout so write to OUTBOUND queue
5304: -- do not set the correlation here for compatibility reason
5305: wf_queue.enqueue_event
5306: (queuename=>wf_queue.OutboundQueue,
5307: itemtype=> act.item_type,
5308: itemkey=>itemkey,
5309: actid=>act.process_activity,

Line 5306: (queuename=>wf_queue.OutboundQueue,

5302: elsif act_ftype = 'EXTERNAL' then
5303: -- this is a callout so write to OUTBOUND queue
5304: -- do not set the correlation here for compatibility reason
5305: wf_queue.enqueue_event
5306: (queuename=>wf_queue.OutboundQueue,
5307: itemtype=> act.item_type,
5308: itemkey=>itemkey,
5309: actid=>act.process_activity,
5310: funcname=>act_fname,

Line 5311: paramlist=>wf_queue.get_param_list(act.item_type,itemkey,

5307: itemtype=> act.item_type,
5308: itemkey=>itemkey,
5309: actid=>act.process_activity,
5310: funcname=>act_fname,
5311: paramlist=>wf_queue.get_param_list(act.item_type,itemkey,
5312: act.process_activity),
5313: message_handle=>msg_id);
5314: else
5315: -- this is a callout so write to OUTBOUND queue for other type

Line 5316: wf_queue.enqueue_event

5312: act.process_activity),
5313: message_handle=>msg_id);
5314: else
5315: -- this is a callout so write to OUTBOUND queue for other type
5316: wf_queue.enqueue_event
5317: (queuename=>wf_queue.OutboundQueue,
5318: itemtype=> act.item_type,
5319: itemkey=>itemkey,
5320: actid=>act.process_activity,

Line 5317: (queuename=>wf_queue.OutboundQueue,

5313: message_handle=>msg_id);
5314: else
5315: -- this is a callout so write to OUTBOUND queue for other type
5316: wf_queue.enqueue_event
5317: (queuename=>wf_queue.OutboundQueue,
5318: itemtype=> act.item_type,
5319: itemkey=>itemkey,
5320: actid=>act.process_activity,
5321: correlation=>act_ftype,

Line 5323: paramlist=>wf_queue.get_param_list(act.item_type,itemkey,

5319: itemkey=>itemkey,
5320: actid=>act.process_activity,
5321: correlation=>act_ftype,
5322: funcname=>act_fname,
5323: paramlist=>wf_queue.get_param_list(act.item_type,itemkey,
5324: act.process_activity),
5325: message_handle=>msg_id);
5326: end if;
5327: