DBA Data[Home] [Help]

APPS.WF_QUEUE dependencies on WF_ENGINE

Line 99: nvalue number; --required but not used by wf_engine.CB

95: aname varchar2(40);
96: avalue varchar2(4000);
97: lcorrelation varchar2(80);
98:
99: nvalue number; --required but not used by wf_engine.CB
100: dvalue date; --required but not used by wf_engine.CB
101:
102: begin
103:

Line 100: dvalue date; --required but not used by wf_engine.CB

96: avalue varchar2(4000);
97: lcorrelation varchar2(80);
98:
99: nvalue number; --required but not used by wf_engine.CB
100: dvalue date; --required but not used by wf_engine.CB
101:
102: begin
103:
104: --process the parameter list.

Line 123: wf_engine.SetItemAttrText(itemtype, itemkey,

119: avalue := substr(attrpair,instr(attrpair,'=')+1);
120:
121: begin
122: --Set the value for the attribute
123: wf_engine.SetItemAttrText(itemtype, itemkey,
124: aname, avalue);
125: exception when others then
126: if ( wf_core.error_name = 'WFENG_ITEM_ATTR' ) then
127: --If the attribute does not exist first create it

Line 129: Wf_Engine.AddItemAttr(itemtype, itemkey, aname);

125: exception when others then
126: if ( wf_core.error_name = 'WFENG_ITEM_ATTR' ) then
127: --If the attribute does not exist first create it
128: --and then add the value
129: Wf_Engine.AddItemAttr(itemtype, itemkey, aname);
130: Wf_Engine.SetItemAttrText(itemtype, itemkey, aname, avalue);
131: else
132: raise;
133: end if;

Line 130: Wf_Engine.SetItemAttrText(itemtype, itemkey, aname, avalue);

126: if ( wf_core.error_name = 'WFENG_ITEM_ATTR' ) then
127: --If the attribute does not exist first create it
128: --and then add the value
129: Wf_Engine.AddItemAttr(itemtype, itemkey, aname);
130: Wf_Engine.SetItemAttrText(itemtype, itemkey, aname, avalue);
131: else
132: raise;
133: end if;
134: end;

Line 152: wf_engine.CB(command => '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',
153: context =>itemtype||':'||
154: itemkey ||':'||
155: actid,
156: text_value => p_payload.result,

Line 176: wf_engine.CB(command => 'ERROR',

172: end;
173: --function name on payload is upto 200 char so use it to record error
174: wf_core.error_stack := p_payload.function_name;
175:
176: wf_engine.CB(command => 'ERROR',
177: context =>itemtype||':'||
178: itemkey ||':'||
179: actid,
180: text_value => p_payload.result,

Line 403: wf_engine.eng_active, null, null, null);

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
407:

Line 413: Wf_Engine_Util.Process_Activity(itemtype, itemkey, actid,

409: begin
410:
411: savepoint wf_savepoint;
412:
413: Wf_Engine_Util.Process_Activity(itemtype, itemkey, actid,
414: maxthreshold, TRUE);
415:
416: -- we successfully processed the activity so dequeue it.
417: wf_queue.PurgeEvent(wf_queue.DeferredQueue, message_handle, TRUE);

Line 433: Wf_Core.Token('ACTIVITY', Wf_Engine.GetActivityLabel(actid));

429: end;
430: exception
431: when NO_SAVEPOINT then
432: -- Catch any savepoint error in case of a commit happened.
433: Wf_Core.Token('ACTIVITY', Wf_Engine.GetActivityLabel(actid));
434: Wf_Core.Raise('WFENG_COMMIT_IN_PROCESS');
435: end;
436: exception
437: when OTHERS then

Line 447: wf_engine.eng_exception, FALSE);

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;
451: end;

Line 448: Wf_Engine_Util.Execute_Error_Process(itemtype, itemkey,

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;
451: end;
452:

Line 449: actid, wf_engine.eng_exception);

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;
451: end;
452:
453: -- Commit work to insure this activity thread doesn't interfere

Line 561: lvalue := wf_engine.GetItemAttrText(itemtype,itemkey,

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
560: -- null itemattr text_value means null value, not an error
561: lvalue := wf_engine.GetItemAttrText(itemtype,itemkey,
562: attr_row.text_value);
563: else --must be CONSTANT
564: if (attr_row.type = 'NUMBER') then
565: if (attr_row.format is null) then

Line 971: Wf_Engine.SetItemAttrNumber(itemtype=>enqueue_event.itemtype,

967:
968: begin
969: -- Add a run-time item attribute of #DELAY_ACTID_ to track the
970: -- continuous loop
971: Wf_Engine.SetItemAttrNumber(itemtype=>enqueue_event.itemtype,
972: itemkey=>enqueue_event.itemkey,
973: aname=>'#DELAY_ACTID_'||enqueue_event.actid,
974: avalue=>l_increment_delay);
975: exception

Line 979: Wf_Engine.AddItemAttr(itemtype=>enqueue_event.itemtype,

975: exception
976: when others then
977: if (wf_core.error_name = 'WFENG_ITEM_ATTR') then
978: Wf_Core.Clear;
979: Wf_Engine.AddItemAttr(itemtype=>enqueue_event.itemtype,
980: itemkey=>enqueue_event.itemkey,
981: aname=>'#DELAY_ACTID_'||enqueue_event.actid,
982: number_value=>l_increment_delay);
983: else