DBA Data[Home] [Help]

APPS.WF_QUEUE dependencies on WF_ITEM

Line 148: wf_item_activity_status.status(itemtype,itemkey,actid,status);

144:
145: colon:= instr(p_payload.result,':');
146: if colon=0 or p_payload.result is null then
147: -- check if activity is already complete
148: wf_item_activity_status.status(itemtype,itemkey,actid,status);
149: if (status is not null)
150: and (status <> 'COMPLETE') then
151: -- mark activity as Complete:
152: wf_engine.CB(command => 'COMPLETE',

Line 402: Wf_Item_Activity_Status.Create_Status(itemtype, itemkey, actid,

398: minthreshold in number,
399: maxthreshold in number)
400: as
401: begin
402: Wf_Item_Activity_Status.Create_Status(itemtype, itemkey, actid,
403: wf_engine.eng_active, null, null, null);
404:
405: -- Continue processing on activity
406: begin

Line 446: Wf_Item_Activity_Status.Set_Error(itemtype, itemkey, actid,

442: -- **note the error stack will refer to the actid that has been
443: -- rolled back!
444: Wf_Core.Context('Wf_Queue', 'ProcessDeferredEvent', itemtype,
445: to_char(minthreshold), to_char(maxthreshold));
446: Wf_Item_Activity_Status.Set_Error(itemtype, itemkey, actid,
447: wf_engine.eng_exception, FALSE);
448: Wf_Engine_Util.Execute_Error_Process(itemtype, itemkey,
449: actid, wf_engine.eng_exception);
450: Wf_Core.Clear;

Line 555: startdate:=wf_item.active_date(itemtype,itemkey);

551: order by aa.sequence;
552:
553: begin
554: paramlist:=null;
555: startdate:=wf_item.active_date(itemtype,itemkey);
556:
557: for attr_row in attr_list loop
558: if (attr_row.value_type = 'ITEMATTR' and
559: attr_row.text_value is not null) then

Line 839: FROM WF_ITEM_ACTIVITY_STATUSES CWIAS,

835: -- check begin date as well
836: -- move the BEGIN_DATE, SYSDATE comparion to a separate clause
837: SELECT CWA.COST, CWIAS.BEGIN_DATE
838: into cost, l_begdate
839: FROM WF_ITEM_ACTIVITY_STATUSES CWIAS,
840: WF_PROCESS_ACTIVITIES CWPA,
841: WF_ITEMS WI,
842: WF_ACTIVITIES CWA
843: where CWIAS.ACTIVITY_STATUS = 'DEFERRED'

Line 841: WF_ITEMS WI,

837: SELECT CWA.COST, CWIAS.BEGIN_DATE
838: into cost, l_begdate
839: FROM WF_ITEM_ACTIVITY_STATUSES CWIAS,
840: WF_PROCESS_ACTIVITIES CWPA,
841: WF_ITEMS WI,
842: WF_ACTIVITIES CWA
843: where CWIAS.ACTIVITY_STATUS = 'DEFERRED'
844: and CWIAS.PROCESS_ACTIVITY = CWPA.INSTANCE_ID
845: and CWPA.ACTIVITY_ITEM_TYPE = CWA.ITEM_TYPE

Line 942: from wf_item_activity_statuses_h

938: (g_ActivityHistoryCount(g_Key).ACTID <> enqueue_event.actid)) then
939:
940: select count(process_activity)
941: into l_background_occurrence
942: from wf_item_activity_statuses_h
943: where item_type = enqueue_event.itemtype
944: and item_key = enqueue_event.itemkey
945: and process_activity = enqueue_event.actid
946: and begin_date >= g_background_begin_date;

Line 1123: if wf_item.acquire_lock(payload.itemtype, payload.itemkey) then

1119: --Ensure that we have got a message
1120: --Now try to acquire the lock
1121: --Check the parameterlist null/not within Process_Inbound_Event
1122:
1123: if wf_item.acquire_lock(payload.itemtype, payload.itemkey) then
1124: --Process the payload
1125: wf_queue.Process_Inbound_Event(itemtype=>payload.itemtype,
1126: itemkey=>payload.itemkey,
1127: actid=>payload.actid,

Line 1236: wf_item.acquire_lock(payload.itemtype,payload.itemkey) then

1232: message_handle,
1233: maxthreshold,
1234: minthreshold )
1235: AND
1236: wf_item.acquire_lock(payload.itemtype,payload.itemkey) then
1237:
1238: wf_queue.ProcessDeferredEvent(itemtype=>payload.itemtype,
1239: itemkey=>payload.itemkey,
1240: actid=>payload.actid,