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 3894: wf_queue.Enablebackgroundqueues;

3890: end if;
3891:
3892: --Bug 2307428
3893: --Enable the deferred and inbound queues.
3894: wf_queue.Enablebackgroundqueues;
3895:
3896: -- Do not need to preserve context
3897: wf_engine.preserved_context := FALSE;
3898:

Line 3905: wf_queue.ProcessInboundQueue(itemtype);

3901:
3902: -- Process deferred activities
3903: if (process_deferred) then
3904: -- process the inbound queue first - it may place events on the deferred Q
3905: wf_queue.ProcessInboundQueue(itemtype);
3906: wf_engine.ProcessDeferred(itemtype, minthreshold, maxthreshold);
3907: end if;
3908:
3909: -- Process timeout activities

Line 5346: wf_queue.enqueue_event

5342: delay :=0;
5343: else
5344: delay := round((act.begin_date - sysdate)*24*60*60 + 0.5);
5345: end if;
5346: wf_queue.enqueue_event
5347: (queuename=>wf_queue.DeferredQueue,
5348: itemtype=> act.item_type,
5349: itemkey=>itemkey,
5350: actid=>act.process_activity,

Line 5347: (queuename=>wf_queue.DeferredQueue,

5343: else
5344: delay := round((act.begin_date - sysdate)*24*60*60 + 0.5);
5345: end if;
5346: wf_queue.enqueue_event
5347: (queuename=>wf_queue.DeferredQueue,
5348: itemtype=> act.item_type,
5349: itemkey=>itemkey,
5350: actid=>act.process_activity,
5351: delay=>delay,

Line 5359: wf_queue.enqueue_event

5355: --msg_id :=null;
5356: elsif act_ftype = 'EXTERNAL' then
5357: -- this is a callout so write to OUTBOUND queue
5358: -- do not set the correlation here for compatibility reason
5359: wf_queue.enqueue_event
5360: (queuename=>wf_queue.OutboundQueue,
5361: itemtype=> act.item_type,
5362: itemkey=>itemkey,
5363: actid=>act.process_activity,

Line 5360: (queuename=>wf_queue.OutboundQueue,

5356: elsif act_ftype = 'EXTERNAL' then
5357: -- this is a callout so write to OUTBOUND queue
5358: -- do not set the correlation here for compatibility reason
5359: wf_queue.enqueue_event
5360: (queuename=>wf_queue.OutboundQueue,
5361: itemtype=> act.item_type,
5362: itemkey=>itemkey,
5363: actid=>act.process_activity,
5364: funcname=>act_fname,

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

5361: itemtype=> act.item_type,
5362: itemkey=>itemkey,
5363: actid=>act.process_activity,
5364: funcname=>act_fname,
5365: paramlist=>wf_queue.get_param_list(act.item_type,itemkey,
5366: act.process_activity),
5367: message_handle=>msg_id);
5368: else
5369: -- this is a callout so write to OUTBOUND queue for other type

Line 5370: wf_queue.enqueue_event

5366: act.process_activity),
5367: message_handle=>msg_id);
5368: else
5369: -- this is a callout so write to OUTBOUND queue for other type
5370: wf_queue.enqueue_event
5371: (queuename=>wf_queue.OutboundQueue,
5372: itemtype=> act.item_type,
5373: itemkey=>itemkey,
5374: actid=>act.process_activity,

Line 5371: (queuename=>wf_queue.OutboundQueue,

5367: message_handle=>msg_id);
5368: else
5369: -- this is a callout so write to OUTBOUND queue for other type
5370: wf_queue.enqueue_event
5371: (queuename=>wf_queue.OutboundQueue,
5372: itemtype=> act.item_type,
5373: itemkey=>itemkey,
5374: actid=>act.process_activity,
5375: correlation=>act_ftype,

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

5373: itemkey=>itemkey,
5374: actid=>act.process_activity,
5375: correlation=>act_ftype,
5376: funcname=>act_fname,
5377: paramlist=>wf_queue.get_param_list(act.item_type,itemkey,
5378: act.process_activity),
5379: message_handle=>msg_id);
5380: end if;
5381: