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 837: FROM WF_ITEM_ACTIVITY_STATUSES CWIAS,

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

Line 839: WF_ITEMS WI,

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

Line 915: l_inst_id WF_ITEMS.INST_ID%TYPE;

911: message_properties dbms_aq.message_properties_t;
912: l_increment_delay number;
913: l_min_delay number;
914: l_background_occurrence number;
915: l_inst_id WF_ITEMS.INST_ID%TYPE;
916: l_process WF_ITEMS.ROOT_ACTIVITY%TYPE;
917:
918: begin
919:

Line 916: l_process WF_ITEMS.ROOT_ACTIVITY%TYPE;

912: l_increment_delay number;
913: l_min_delay number;
914: l_background_occurrence number;
915: l_inst_id WF_ITEMS.INST_ID%TYPE;
916: l_process WF_ITEMS.ROOT_ACTIVITY%TYPE;
917:
918: begin
919:
920: l_increment_delay := delay;

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 1017: from WF_ITEMS

1013: else
1014: message_properties.correlation := wf_queue.account_name||itemtype;
1015: l_inst_id := sys_context('WF_RAC_CTX','INST_ID');
1016: select ROOT_ACTIVITY into l_process
1017: from WF_ITEMS
1018: where ITEM_TYPE=itemtype
1019: and ITEM_KEY=itemkey;
1020: if l_inst_id is not null and WF_ENGINE_RAC.Process_Is_RAC_Enabled(itemtype, l_process) then
1021: message_properties.correlation := message_properties.correlation||':'||l_inst_id;

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

1126: --Ensure that we have got a message
1127: --Now try to acquire the lock
1128: --Check the parameterlist null/not within Process_Inbound_Event
1129:
1130: if wf_item.acquire_lock(payload.itemtype, payload.itemkey) then
1131: --Process the payload
1132: wf_queue.Process_Inbound_Event(itemtype=>payload.itemtype,
1133: itemkey=>payload.itemkey,
1134: actid=>payload.actid,

Line 1177: l_inst_id WF_ITEMS.INST_ID%TYPE;

1173: message_handle raw(16);
1174: -- first_time boolean := TRUE;
1175: nothing_processed boolean:=TRUE;
1176: lcorrelation varchar2(80);
1177: l_inst_id WF_ITEMS.INST_ID%TYPE;
1178:
1179: begin
1180:
1181: -- Bug 4005674

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

1249: message_handle,
1250: maxthreshold,
1251: minthreshold )
1252: AND
1253: wf_item.acquire_lock(payload.itemtype,payload.itemkey) then
1254:
1255: wf_queue.ProcessDeferredEvent(itemtype=>payload.itemtype,
1256: itemkey=>payload.itemkey,
1257: actid=>payload.actid,