DBA Data[Home] [Help]

APPS.WF_EVENT_PING_PKG dependencies on WF_EVENT

Line 1: package body WF_EVENT_PING_PKG as

1: package body WF_EVENT_PING_PKG as
2: /* $Header: WFEVPNGB.pls 120.1.12010000.3 2009/04/22 00:02:47 alepe ship $ */
3: ------------------------------------------------------------------------------
4:
5: -- Send PING and ACK to only WF addresses. For PINGing other addresses, this test

Line 17: and upper(wfa.queue_handler) = 'WF_EVENT_QH'

13: and wfa.name = nvl(p_agent, wfa.name)
14: and wfa.status = 'ENABLED'
15: and wfa.direction = 'IN'
16: and wfa.system_guid = wfs.guid
17: and upper(wfa.queue_handler) = 'WF_EVENT_QH'
18: and wfa.name like 'WF%'
19: and wfa.status = 'ENABLED'
20: and wfs.name = nvl(p_system, wfs.name);
21:

Line 46: l_sys_name := wf_event.local_system_name;

42: l_agent_name := substr(pAgentName, 1, l_atsign-1);
43: l_sys_name := substr(pAgentName, l_atsign+1);
44: else
45: l_agent_name := 'WF_OUT';
46: l_sys_name := wf_event.local_system_name;
47: end if;
48:
49: -- agent should exist, be enabled, be an OUT agent, and its queue handler be
50: -- 'WF_EVENT_QH'

Line 50: -- 'WF_EVENT_QH'

46: l_sys_name := wf_event.local_system_name;
47: end if;
48:
49: -- agent should exist, be enabled, be an OUT agent, and its queue handler be
50: -- 'WF_EVENT_QH'
51: begin
52: SELECT a.name into queName
53: FROM wf_agents a,
54: wf_systems s

Line 57: AND a.queue_handler = 'WF_EVENT_QH'

53: FROM wf_agents a,
54: wf_systems s
55: WHERE a.direction = 'OUT'
56: AND a.status = 'ENABLED'
57: AND a.queue_handler = 'WF_EVENT_QH'
58: AND a.system_guid = s.guid
59: AND s.name = l_sys_name
60: AND a.name = l_agent_name;
61:

Line 68: 'it is not an OUT agent, or its queue handler is not WF_EVENT_QH '||

64: when NO_DATA_FOUND then
65: -- initialize error
66: errorMsg := 'Cannot progress workflow, because either: the agent '||
67: pAgentName ||' is disabled, '||
68: 'it is not an OUT agent, or its queue handler is not WF_EVENT_QH '||
69: '(for WF_EVENT_T payload type).';
70:
71: raise_application_error(-20000,errorMsg);
72: when others then

Line 69: '(for WF_EVENT_T payload type).';

65: -- initialize error
66: errorMsg := 'Cannot progress workflow, because either: the agent '||
67: pAgentName ||' is disabled, '||
68: 'it is not an OUT agent, or its queue handler is not WF_EVENT_QH '||
69: '(for WF_EVENT_T payload type).';
70:
71: raise_application_error(-20000,errorMsg);
72: when others then
73: null;

Line 93: l_event_t wf_event_t;

89:
90: l_eventname varchar2(100);
91: l_eventkey varchar2(240);
92: l_itemkey varchar2(100);
93: l_event_t wf_event_t;
94: l_msg varchar2(32000);
95: l_clob clob;
96: l_outAgent varchar2(100);
97: l_toAgent varchar2(100);

Line 168: -- Initialise the wf_event_t

164: itemkey => l_itemkey,
165: aname => 'TOAGENT',
166: avalue => x.agent||'@'||x.system);
167:
168: -- Initialise the wf_event_t
169: wf_event_t.initialize(l_event_t);
170: l_event_t.setcorrelationid(l_itemkey);
171: l_msg := 'Test Ping';
172: dbms_lob.createtemporary(l_clob, FALSE, DBMS_LOB.CALL);

Line 169: wf_event_t.initialize(l_event_t);

165: aname => 'TOAGENT',
166: avalue => x.agent||'@'||x.system);
167:
168: -- Initialise the wf_event_t
169: wf_event_t.initialize(l_event_t);
170: l_event_t.setcorrelationid(l_itemkey);
171: l_msg := 'Test Ping';
172: dbms_lob.createtemporary(l_clob, FALSE, DBMS_LOB.CALL);
173: dbms_lob.write(l_clob, length(l_msg), 1 , l_msg);

Line 207: WF_CORE.CONTEXT('WF_EVENT_PING_PKG', 'LAUNCH_PROCESSES', ITEMTYPE, ITEMKEY, to_char(ACTID), FUNCMODE);

203: end if;
204:
205: exception
206: when others then
207: WF_CORE.CONTEXT('WF_EVENT_PING_PKG', 'LAUNCH_PROCESSES', ITEMTYPE, ITEMKEY, to_char(ACTID), FUNCMODE);
208: raise;
209: end LAUNCH_PROCESSES;
210: ------------------------------------------------------------------------------
211: function ACKNOWLEDGE (

Line 213: P_EVENT in out nocopy wf_event_t

209: end LAUNCH_PROCESSES;
210: ------------------------------------------------------------------------------
211: function ACKNOWLEDGE (
212: P_SUBSCRIPTION_GUID in raw,
213: P_EVENT in out nocopy wf_event_t
214: ) return varchar2 is
215: ------------------------------------------------------------------------------
216: l_fromagent wf_agent_t;
217: l_result varchar2(100);

Line 224: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Begin',

220: begin
221:
222: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
223: wf_log_pkg.string(wf_log_pkg.level_procedure,
224: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Begin',
225: ' Started');
226: end if;
227:
228: l_returnsys := p_event.from_agent.system;

Line 232: l_fromagent := wf_agent_t ('WF_OUT', wf_event.local_system_name);

228: l_returnsys := p_event.from_agent.system;
229:
230: -- Setting FROM AGENT for ACK message. Default to WF_OUT agent to
231: -- send ACK message via
232: l_fromagent := wf_agent_t ('WF_OUT', wf_event.local_system_name);
233: p_event.SetFromAgent(l_fromagent);
234:
235: -- Setting TO AGENT for ACK message. ACK message back to originating system,
236: -- we will pick first matching IN agent on the originating system, registered

Line 248: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.ToAgent',

244: p_event.to_agent.system := l_returnsys;
245:
246: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
247: wf_log_pkg.string(wf_log_pkg.level_statement,
248: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.ToAgent',
249: 'To Agent:'||p_event.to_agent.name);
250: wf_log_pkg.string(wf_log_pkg.level_statement,
251: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.ToSystem',
252: 'To System:'||p_event.to_agent.system);

Line 251: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.ToSystem',

247: wf_log_pkg.string(wf_log_pkg.level_statement,
248: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.ToAgent',
249: 'To Agent:'||p_event.to_agent.name);
250: wf_log_pkg.string(wf_log_pkg.level_statement,
251: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.ToSystem',
252: 'To System:'||p_event.to_agent.system);
253: wf_log_pkg.string(wf_log_pkg.level_statement,
254: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromAgent',
255: 'From Agent:'||p_event.from_agent.name);

Line 254: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromAgent',

250: wf_log_pkg.string(wf_log_pkg.level_statement,
251: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.ToSystem',
252: 'To System:'||p_event.to_agent.system);
253: wf_log_pkg.string(wf_log_pkg.level_statement,
254: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromAgent',
255: 'From Agent:'||p_event.from_agent.name);
256: wf_log_pkg.string(wf_log_pkg.level_statement,
257: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromSystem',
258: 'From System:'||p_event.from_agent.system);

Line 257: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromSystem',

253: wf_log_pkg.string(wf_log_pkg.level_statement,
254: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromAgent',
255: 'From Agent:'||p_event.from_agent.name);
256: wf_log_pkg.string(wf_log_pkg.level_statement,
257: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromSystem',
258: 'From System:'||p_event.from_agent.system);
259: end if;
260:
261: p_event.SetEventName('oracle.apps.wf.event.test.ack');

Line 261: p_event.SetEventName('oracle.apps.wf.event.test.ack');

257: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.FromSystem',
258: 'From System:'||p_event.from_agent.system);
259: end if;
260:
261: p_event.SetEventName('oracle.apps.wf.event.test.ack');
262:
263: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
264: wf_log_pkg.string(wf_log_pkg.level_statement,
265: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Send',

Line 265: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Send',

261: p_event.SetEventName('oracle.apps.wf.event.test.ack');
262:
263: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
264: wf_log_pkg.string(wf_log_pkg.level_statement,
265: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Send',
266: 'Sending Event');
267: end if;
268:
269: wf_event.send(

Line 269: wf_event.send(

265: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Send',
266: 'Sending Event');
267: end if;
268:
269: wf_event.send(
270: p_event => p_event);
271:
272: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
273: wf_log_pkg.string(wf_log_pkg.level_statement,

Line 274: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Sent',

270: p_event => p_event);
271:
272: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
273: wf_log_pkg.string(wf_log_pkg.level_statement,
274: 'wf.plsqlWF_EVENT_PING_PKG.ACKNOWLEDGE.Sent',
275: ' Sent');
276: end if;
277:
278: l_result := wf_rule.default_rule(p_subscription_guid, p_event);

Line 284: WF_CORE.CONTEXT('WF_EVENT_PING_PKG','ACKNOWLEDGE',p_event.event_name,p_event.event_key, p_event.correlation_id);

280: return(l_result);
281:
282: exception
283: when others then
284: WF_CORE.CONTEXT('WF_EVENT_PING_PKG','ACKNOWLEDGE',p_event.event_name,p_event.event_key, p_event.correlation_id);
285: wf_event.setErrorInfo(p_event,'ERROR');
286: return('ERROR');
287: end;
288:

Line 285: wf_event.setErrorInfo(p_event,'ERROR');

281:
282: exception
283: when others then
284: WF_CORE.CONTEXT('WF_EVENT_PING_PKG','ACKNOWLEDGE',p_event.event_name,p_event.event_key, p_event.correlation_id);
285: wf_event.setErrorInfo(p_event,'ERROR');
286: return('ERROR');
287: end;
288:
289: end WF_EVENT_PING_PKG;

Line 289: end WF_EVENT_PING_PKG;

285: wf_event.setErrorInfo(p_event,'ERROR');
286: return('ERROR');
287: end;
288:
289: end WF_EVENT_PING_PKG;