[Home] [Help]
100: func := l_event_obj.GENERATE_FUNCTION;
101:
102: if (func is not null) then
103:
104: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
105: wf_log_pkg.string2(wf_log_pkg.level_statement,
106: 'wf.plsql.wf_event.SetMessage.genfunc_callout',
107: 'Start executing generate function - '||func, true);
108: end if;
131: execute immediate cmd using in out msg, in ename, in ekey;
132: end;
133: end if;
134:
135: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
136: wf_log_pkg.string2(wf_log_pkg.level_statement,
137: 'wf.plsql.wf_event.SetMessage.genfunc_callout',
138: 'End executing generate function - '||func, false);
139: end if;
172: err_msg varchar2(2000);
173: err_stack varchar2(2000);
174: begin
175:
176: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
177: wf_log_pkg.string(wf_log_pkg.level_procedure,
178: 'wf.plsql.WF_EVENT.setErrorInfo.begin',
179: 'Setting Error Info');
180: end if;
207: erragt wf_agent_t;
208: cmd varchar2(1000);
209: begin
210:
211: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
212: wf_log_pkg.string(wf_log_pkg.level_procedure,
213: 'wf.plsql.WF_EVENT.saveErrorToQueue.Begin',
214: 'saving event to WF_ERROR on '|| wf_event.local_system_name);
215: end if;
223:
224: --cmd := 'begin WF_ERROR_QH.enqueue(:v1, :v2); end;';
225: --execute immediate cmd using in p_event,
226: -- in erragt;
227: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
228: wf_log_pkg.string(wf_log_pkg.level_procedure,
229: 'wf.plsql.WF_EVENT.saveErrorToQueue.End',
230: 'error info saved');
231: end if;
246: erragt wf_agent_t;
247: cmd varchar2(1000);
248: begin
249:
250: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
251: wf_log_pkg.string(wf_log_pkg.level_procedure,
252: 'wf.plsql.WF_EVENT.saveErrorToJavaQueue.Begin',
253: 'saving event to WF_JAVA_ERROR on '|| wf_event.local_system_name);
254: end if;
262:
263: --cmd := 'begin WF_ERROR_QH.enqueue(:v1, :v2); end;';
264: --execute immediate cmd using in p_event,
265: -- in erragt;
266: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
267: wf_log_pkg.string(wf_log_pkg.level_procedure,
268: 'wf.plsql.WF_EVENT.saveErrorToJavaQueue.End',
269: 'error info saved');
270: end if;
299: l_phase number;
300: l_rule_func varchar2(240);
301: l_rule_data varchar2(8);
302: begin
303: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
304: wf_log_pkg.string(wf_log_pkg.level_procedure,
305: 'wf.plsql.WF_EVENT.isDeferToJava.begin',
306: 'Checking for Java subscription/generate');
307: end if;
308:
309: if (p_rule_func is not null AND
310: UPPER(substr(p_rule_func, 0, length(java_sub))) = UPPER(java_sub)) then
311: -- this is a Java subscription. Return true
312: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
313: wf_log_pkg.string(wf_log_pkg.level_statement,
314: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
315: 'found a Java subscription');
316: end if;
336:
337: if (l_java_gen AND p_rule_data is not null AND
338: p_rule_data = 'MESSAGE' and p_source_type = 'LOCAL') then
339: -- this is a Java generate function.
340: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
341: wf_log_pkg.string(wf_log_pkg.level_statement,
342: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
343: 'found a Java generate function');
344: end if;
372: end loop;
373: end if;
374:
375: if(l_java_defer) then
376: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
377: wf_log_pkg.string(wf_log_pkg.level_statement,
378: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
379: 'found subsequent Java sub or java generate');
380: end if;
379: 'found subsequent Java sub or java generate');
380: end if;
381: return true;
382: else
383: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
384: wf_log_pkg.string(wf_log_pkg.level_statement,
385: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
386: 'No Java sub found or Java Generate Found');
387: end if;
388: return false;
389: end if;
390: end if;
391:
392: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
393: wf_log_pkg.string(wf_log_pkg.level_procedure,
394: 'wf.plsql.WF_EVENT.isDeferToJava.end',
395: 'Checked for Java subscription/generate');
396: end if;
413: p_rule_func in varchar2)
414: return boolean is
415:
416: begin
417: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
418: wf_log_pkg.string(wf_log_pkg.level_procedure,
419: 'wf.plsql.WF_EVENT.isSaveToJavaError.begin',
420: 'Checking Java Error subscription for ' || p_event_name);
421: end if;
422:
423: if (p_rule_func is not null AND
424: UPPER(substr(p_rule_func, 0, length(java_sub))) = UPPER(java_sub)) then
425: -- this is a Java subscription. Return true
426: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
427: wf_log_pkg.string(wf_log_pkg.level_statement,
428: 'wf.plsql.WF_EVENT.isSaveToJavaError.Subscription',
429: 'found a Java subscription');
430: end if;
487: -- Bug 11850350. If database is in PATCH EDITION then
488: -- do not process the event at all. Just return
489: if (wf_core.database_current_edition <> wf_core.database_default_edition) and
490: (p_event.send_date is null or p_event.send_date <= sysdate) then
491: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
492: wf_log_pkg.string(wf_log_pkg.level_statement,
493: 'wf.plsql.WF_EVENT.dispatch_internal',
494: 'Database not in RUN edition - discarding event');
495: end if;
542: if (wf_event.phase_maxthreshold is not null) AND
543: (p_phase >= wf_event.phase_maxthreshold) AND
544: (p_source_type <> 'ERROR')
545: then
546: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
547: wf_log_pkg.string(wf_log_pkg.level_statement,
548: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
549: 'max threshold reached');
550: end if;
562: p_rule_func);
563: end if;
564:
565: if(defer_to_java OR max_threshold_reached ) then
566: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
567: wf_log_pkg.string(wf_log_pkg.level_statement,
568: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
569: 'detected as deferred');
570: end if;
587: -- So in such case, Value of #CURRENT_PHASE will be used as starting phase.
588: p_event.AddParameterToList('#CURRENT_PHASE', p_phase);
589:
590: if(defer_to_java) then
591: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
592: wf_log_pkg.string(wf_log_pkg.level_statement,
593: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
594: 'deferring to WF_JAVA_DEFERRED');
595: end if;
594: 'deferring to WF_JAVA_DEFERRED');
595: end if;
596: wf_event.DeferEventToJava(p_source_type, p_event);
597: else
598: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
599: wf_log_pkg.string(wf_log_pkg.level_statement,
600: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
601: 'deferring to WF_DEFERRED');
602: end if;
604: end if;
605: res := 'DEFER';
606:
607: elsif (save_to_java_error) then
608: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
609: wf_log_pkg.string(wf_log_pkg.level_statement,
610: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
611: 'save to java error queue');
612: end if;
624: begin
625: if (NOT genmsg) AND
626: (p_rule_data = 'MESSAGE') AND
627: (p_source_type = 'LOCAL') then
628: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
629: wf_log_pkg.string(wf_log_pkg.level_statement,
630: 'wf.plsql.WF_EVENT.dispatch_internal.Rule_Data',
631: 'Rule Data is MESSAGE and Source is LOCAL');
632: end if;
634: -- Bug Fix for 4286207
635: begin
636: if (p_event.GetEventData() is null) or
637: (p_event.GetEventData() is not null and dbms_lob.getlength(p_event.GetEventData()) = 0) then
638: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
639: wf_log_pkg.string(wf_log_pkg.level_statement,
640: 'wf.plsql.WF_EVENT.dispatch_internal.generate',
641: 'Need to Generate Message');
642: end if;
645: end if;
646: exception
647: when empty_lob_locator then
648: -- The lob locator is invalid, probably pointing to a empty_clob();
649: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
650: wf_log_pkg.string(wf_log_pkg.level_statement,
651: 'wf.plsql.WF_EVENT.dispatch_internal.generate',
652: 'Invalid Lob Locator Passed, Generate the Message');
653: end if;
689: -- just execute the default dispatch functionality
690: --
691: begin
692:
693: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
694: wf_log_pkg.string2(wf_log_pkg.level_statement,
695: 'wf.plsql.wf_event.dispatch_internal.rulefunc_callout',
696: 'Start executing rule function - '||p_rule_func, true);
697: end if;
713: in out p_event;
714: end if;
715: end if;
716:
717: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
718: wf_log_pkg.string2(wf_log_pkg.level_statement,
719: 'wf.plsql.wf_event.dispatch_internal.rulefunc_callout',
720: 'End executing rule function - '||p_rule_func, false);
721: end if;
740: end if;
741:
742: end;
743:
744: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
745: -- BINDVAR_SCAN_IGNORE[3]
746: wf_log_pkg.string(wf_log_pkg.level_statement,
747: 'wf.plsql.WF_EVENT.dispatch_internal.rule_function',
748: 'Executed Rule Function '||myfunc||' and returned '||res);
751: end if; -- End of "defer_to_java OR max_threshold_reached"
752: else
753: -- Bug 4227307
754: -- Handle the subscriptions that are not eligible for execution.
755: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
756: wf_log_pkg.string(wf_log_pkg.level_statement,
757: 'wf.plsql.wf_event.dispatch_internal.subs_ignore',
758: 'Subscription not executed. Sub Phase='||p_phase||
759: ', Min threshold='||wf_event.phase_minthreshold);
925: outagtname := p_event.getFromAgent().getName();
926: outagtsys := p_event.getFromAgent().getSystem();
927: end if;
928:
929: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
930: wf_log_pkg.string(wf_log_pkg.level_statement,
931: 'wf.plsql.WF_EVENT.Send.info',
932: 'To Agt: '||toagtname||' To Agt Sys:'||toagtsys||
933: 'Out Agt: '||outagtname||' Out Agt Sys:'||outagtsys);
976: if (p_event.getSendDate() is NULL) then
977: p_event.setSendDate(sysdate);
978: end if;
979:
980: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
981: wf_log_pkg.string(wf_log_pkg.level_statement,
982: 'wf.plsql.WF_EVENT.send.enqueue',
983: 'Sending from '||outagtname||' to '||toagtname);
984: end if;
1048: elsif (p_to_system_name <> p_out_system_name) then
1049: l_to_address := l_to_agt_obj.ADDRESS;
1050: end if;
1051:
1052: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1053: wf_log_pkg.string(wf_log_pkg.level_statement,
1054: 'wf.plsql.WF_EVENT.Get_Recipient',
1055: 'Recipient is name: ' || p_to_agent_name ||
1056: ' address: ' || l_to_address || ' protocol: ' ||l_to_protocol);
1105: -- if there is a to queue, we need to set the recipient list address
1106: l_to_agent_name := p_event.getToAgent().getName();
1107: l_to_system_name := p_event.getToAgent().getSystem();
1108:
1109: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1110: wf_log_pkg.string(wf_log_pkg.level_statement,
1111: 'wf.plsql.WF_EVENT.setRecieptList',
1112: 'Setting Recipient List: ' || l_to_agent_name);
1113: end if;
1338: if (wf_event.local_system_status in ('LOCAL','EXTERNAL')) then
1339: if (st = wf_event.local_system_status
1340: OR st = 'ERROR'
1341: OR p_agent_name = 'WF_DEFERRED') then
1342: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1343: wf_log_pkg.string(wf_log_pkg.level_statement,
1344: 'wf.plsql.WF_EVENT.listen.Check1',
1345: 'Source type is equal to system status '||
1346: 'or ERROR or Deferred Processing');
1345: 'Source type is equal to system status '||
1346: 'or ERROR or Deferred Processing');
1347: end if;
1348: else
1349: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1350: wf_log_pkg.string(wf_log_pkg.level_statement,
1351: 'wf.plsql.WF_EVENT.listen.Check2',
1352: 'Source type not valid for current system status');
1353: end if;
1384: else
1385: from_agt_name := evt.getFromAgent().getName();
1386: from_agt_sys := evt.getFromAgent().getSystem();
1387:
1388: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1389: wf_log_pkg.string(wf_log_pkg.level_statement,
1390: 'wf.plsql.WF_EVENT.listen',
1391: 'Event '||evt.getEventName()||
1392: ', hailing from '||from_agt_name||'@'||from_agt_sys||
1419: -- Bug 2210085 - starting a new block to capture exceptions thrown
1420: -- by GetDeferEventCtx
1421: begin
1422: if p_agent_name = 'WF_DEFERRED' then
1423: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1424: wf_log_pkg.string(wf_log_pkg.level_statement,
1425: 'wf.plsql.WF_EVENT.listen.Deferred',
1426: 'Processing Deferred Event');
1427: end if;
1454: wfa_sec.Restore_Ctx();
1455:
1456: if (wf_event.wf_exception_source = 'RULE') then
1457: if (st = 'ERROR') then
1458: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1459: wf_log_pkg.string(wf_log_pkg.level_error,
1460: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1461: 'Rule Function with Source Error Exception');
1462: end if;
1461: 'Rule Function with Source Error Exception');
1462: end if;
1463: raise;
1464: else
1465: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1466: wf_log_pkg.string(wf_log_pkg.level_error,
1467: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1468: 'Rule Function Error');
1469: end if;
1472: commit;
1473: l_error_count := l_error_count + 1;
1474: end if;
1475: else
1476: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1477: wf_log_pkg.string(wf_log_pkg.level_error,
1478: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1479: 'Non Rule Function Error');
1480: end if;
1496: -- the event again into the error queue.
1497: -- In this case we just rollback the dequeue and raise the
1498: -- exception to the user.
1499: if (( wf_event.wf_exception_source = 'RULE') and (st = 'ERROR')) then
1500: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1501: wf_log_pkg.string(wf_log_pkg.level_error,
1502: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1503: 'Error executing Rule Function with Source Type Error');
1504: end if;
1516: wf_core.raise('WFE_UNHANDLED_ERROR');
1517: end if;
1518: elsif (wf_event.wf_exception_source = 'WF') then
1519: -- Bug 4207885: Add the handler of exception with source WF
1520: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1521: wf_log_pkg.string(wf_log_pkg.level_error,
1522: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1523: 'Unexpected Function Error');
1524: end if;
1527: wf_core.token('SQLERRM', sqlerrm);
1528: wf_core.token('SQLCODE', sqlcode);
1529: wf_core.raise('WFE_UNHANDLED_ERROR');
1530: else
1531: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1532: wf_log_pkg.string(wf_log_pkg.level_error,
1533: 'wf.plsql.WF_EVENT.listen.error',
1534: 'GetDeferEventCtx Error');
1535: end if;
1550: wf_event.InitPhaseMinThreshold;
1551: wf_event.SetDispatchMode('SYNC');
1552:
1553: if (p_message_count > 0 AND l_lsn_msg_count >= p_message_count ) then
1554: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1555: wf_log_pkg.string(wf_log_pkg.level_statement,
1556: 'wf.plsql.WF_EVENT.listen.maxMsgCount',
1557: 'Read the specified maximum number of messages');
1558: end if;
1559: exit;
1560: end if;
1561:
1562: if (p_max_error_count > 0 AND l_error_count >= p_max_error_count ) then
1563: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1564: wf_log_pkg.string(wf_log_pkg.level_error,
1565: 'wf.plsql.WF_EVENT.listen.maxErrCount',
1566: 'Encountered the specified maximum number of errors');
1567: end if;
1735:
1736: begin --We will begin processing a transaction (message group).
1737: savepoint trxn_start;
1738:
1739: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1740: wf_log_pkg.string(wf_log_pkg.level_statement,
1741: 'wf.plsql.WF_EVENT.Listen_GRP.processing',
1742: 'Begin processing transaction');
1743: end if;
1749: wf_event.dequeue(agt, evt, qh,p_wait);
1750:
1751: exception
1752: when end_of_transaction then
1753: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
1754: wf_log_pkg.string(wf_log_pkg.level_event,
1755: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1756: 'End of the transaction');
1757: end if;
1774: else
1775: from_agt_name := evt.getFromAgent().getName();
1776: from_agt_sys := evt.getFromAgent().getSystem();
1777:
1778: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1779: wf_log_pkg.string(wf_log_pkg.level_statement,
1780: 'wf.plsql.WF_EVENT.Listen_GRP.event_dequeued',
1781: 'Event '||evt.getEventName()||', hailing from '||from_agt_name||'@'||
1782: from_agt_sys|| ' was dequeued from '|| p_agent_name);
1811: wf_event.dispatch(st, sagt, evt);
1812:
1813: exception
1814: when others then
1815: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1816: wf_log_pkg.string(wf_log_pkg.level_error,
1817: 'wf.plsql.WF_EVENT.Listen_GRP.dispatch_error',
1818: 'Dispatch Error when dispatching Event '||evt.getEventName);
1819: end if;
1836: wf_event.dequeue(agt, evt, qh,p_wait);
1837:
1838: exception
1839: when end_of_transaction then
1840: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
1841: wf_log_pkg.string(wf_log_pkg.level_event,
1842: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1843: 'End of the transaction');
1844: end if;
1868: end loop;
1869:
1870: exception
1871: when end_of_transaction then
1872: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
1873: wf_log_pkg.string(wf_log_pkg.level_event,
1874: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1875: 'End of the transaction after dispatch error');
1876: end if;
1997:
1998: -- Deleting any previous Event parameter indexes.
1999: WF_EVENT.evt_param_index.DELETE;
2000:
2001: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2002: wf_log_pkg.string(wf_log_pkg.level_procedure,
2003: 'wf.plsql.WF_EVENT.dispatch.Begin',
2004: 'Dispatching event '||l_event_name);
2005: end if;
2005: end if;
2006:
2007: l_event_obj := wf_bes_cache.GetEventByName(l_event_name);
2008: if (l_event_obj is null) then
2009: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2010: wf_log_pkg.string(wf_log_pkg.level_statement,
2011: 'wf.plsql.WF_EVENT.dispatch.no_event',
2012: 'Event is either disabled or product not licensed '||
2013: 'or event not registered');
2029: l_event_obj is not null) then
2030:
2031: if(isDeferToJava(true, l_event_name, p_source_type,
2032: null, null, null)) then
2033: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2034: wf_log_pkg.string(wf_log_pkg.level_statement,
2035: 'wf.plsql.WF_EVENT.dispatch.Defer',
2036: 'Detected as deferred raise. Deferring to ' ||
2037: 'WF_JAVA_DEFERRED');
2037: 'WF_JAVA_DEFERRED');
2038: end if;
2039: wf_event.DeferEventToJava(p_source_type, p_event);
2040: else
2041: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2042: wf_log_pkg.string(wf_log_pkg.level_statement,
2043: 'wf.plsql.WF_EVENT.dispatch.Defer',
2044: 'Detected as deferred raise. Deferring to ' ||
2045: 'WF_DEFERRED');
2127: -- dispatching all matching subscriptions for the event
2128: if (l_subs_list is not null) then
2129:
2130: for i in 1..l_subs_list.COUNT loop
2131: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2132: wf_log_pkg.string(wf_log_pkg.level_statement,
2133: 'wf.plsql.WF_EVENT.dispatch.Subscriptions',
2134: 'Dispatching '||l_subs_list(i).SOURCE_TYPE||' subscription '||
2135: 'with Phase '||l_subs_list(i).PHASE);
2165: -- dispatching all matching subscriptions for Any event
2166: if (l_subs_list is not null) then
2167:
2168: for i in 1..l_subs_list.COUNT loop
2169: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2170: wf_log_pkg.string(wf_log_pkg.level_statement,
2171: 'wf.plsql.WF_EVENT.dispatch.Any',
2172: 'Dispatching '||l_subs_list(i).SOURCE_TYPE||' subscription '||
2173: 'with Phase '||l_subs_list(i).PHASE);
2202: p_source_agent => dispatch.p_source_agent_guid);
2203: if (l_subs_list is not null) then
2204:
2205: for i in 1..l_subs_list.COUNT loop
2206: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2207: wf_log_pkg.string(wf_log_pkg.level_statement,
2208: 'wf.plsql.WF_EVENT.dispatch.Unexpected',
2209: 'Dispatching '||l_subs_list(i).SOURCE_TYPE||' subscription '||
2210: 'with Phase '||l_subs_list(i).PHASE);
2284:
2285: -- Call the static calls implementation first
2286: p_executed := false;
2287:
2288: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2289: wf_log_pkg.string2(wf_log_pkg.level_statement,
2290: 'wf.plsql.wf_event.enqueue.qhandler_callout',
2291: 'Start executing queue handler - '||qh, true);
2292: end if;
2300: execute immediate cmd using in p_event,
2301: in p_out_agent_override;
2302: end if;
2303:
2304: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2305: wf_log_pkg.string2(wf_log_pkg.level_statement,
2306: 'wf.plsql.wf_event.enqueue.qhandler_callout',
2307: 'End executing queue handler - '||qh, false);
2308: end if;
2349:
2350: -- Call the static calls implementation first
2351: p_executed := false;
2352:
2353: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2354: wf_log_pkg.string2(wf_log_pkg.level_statement,
2355: 'wf.plsql.wf_event.dequeue.qhandler_callout',
2356: 'Start executing queue handler - '||qh, true);
2357: end if;
2365: execute immediate cmd using in p_agent_guid,
2366: out p_event;
2367: end if;
2368:
2369: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2370: wf_log_pkg.string2(wf_log_pkg.level_statement,
2371: 'wf.plsql.wf_event.dequeue.qhandler_callout',
2372: 'End executing queue handler - '||qh, false);
2373: end if;
2476: --while(pos <= myList.COUNT) loop
2477: while(pos is not null) loop
2478: if (myList(pos).getName() = p_Name) then
2479:
2480: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2481: wf_log_pkg.string(wf_log_pkg.level_statement,
2482: 'wf.plsql.WF_EVENT.getValueForParam.get',
2483: 'Name:'||p_Name||' Value:'||myList(pos).getValue());
2484: end if;
2543: defagent wf_agent_t;
2544:
2545: begin
2546:
2547: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2548: wf_log_pkg.string(wf_log_pkg.level_procedure,
2549: 'wf.plsql.WF_EVENT.DeferEvent.Begin',
2550: 'Deferring Event: '||p_event.getEventName());
2551: end if;
2560: -- Deferred Agent/System into the message for
2561: -- reference when we process the event
2562: --
2563: if p_source_type = 'LOCAL' then
2564: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2565: wf_log_pkg.string(wf_log_pkg.level_statement,
2566: 'wf.plsql.WF_EVENT.DeferEvent.Local',
2567: 'Detected as Local, setting From Agent:'||
2568: 'WF_DEFERRED@'||wf_event.local_system_name);
2572:
2573: --
2574: -- Enqueue onto the deferred agent
2575: --
2576: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2577: wf_log_pkg.string(wf_log_pkg.level_statement,
2578: 'wf.plsql.WF_EVENT.DeferEvent.done',
2579: 'Enqueuing on Deferred Queue');
2580: end if;
2596: is
2597: defagent wf_agent_t;
2598:
2599: begin
2600: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2601: wf_log_pkg.string(wf_log_pkg.level_procedure,
2602: 'wf.plsql.WF_EVENT.DeferEventToJava.Begin',
2603: 'Deferring Event: '|| p_event.getEventName());
2604: end if;
2612: -- Deferred Agent/System into the message for
2613: -- reference when we process the event
2614: --
2615: if p_source_type = 'LOCAL' then
2616: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2617: wf_log_pkg.string(wf_log_pkg.level_statement,
2618: 'wf.plsql.WF_EVENT.DeferEventToJava.Local',
2619: 'Detected as Local, setting From Agent:'||
2620: 'WF_JAVA_DEFERRED@'|| wf_event.local_system_name);
2632: -- directly invoke enqueue on the PL/SQL queue handler
2633: --
2634: wf_event_ojmstext_qh.enqueue(p_event, defagent);
2635:
2636: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2637: wf_log_pkg.string(wf_log_pkg.level_statement,
2638: 'wf.plsql.WF_EVENT.DeferEventToJava.done',
2639: 'Enqueuing on Java Deferred Queue');
2640: end if;
2662: l_sub wf_event_subs_obj;
2663: l_event_name varchar2(240);
2664: begin
2665:
2666: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2667: wf_log_pkg.string(wf_log_pkg.level_procedure,
2668: 'wf.plsql.WF_EVENT.DeferEventCtx.Begin',
2669: 'Getting Defer Event Ctx');
2670: end if;
2671: --
2672: -- Determine the Start Phase, and sourec type
2673: --
2674: subguid := p_event.Error_Subscription;
2675: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2676: wf_log_pkg.string(wf_log_pkg.level_statement,
2677: 'wf.plsql.WF_EVENT.DeferEventCtx.sub_guid',
2678: 'Sub Guid is '||subguid);
2679: end if;
2699: else
2700: wf_event.phase_minthreshold := 0; -- for deferred raise
2701: end if;
2702:
2703: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2704: wf_log_pkg.string(wf_log_pkg.level_statement,
2705: 'wf.plsql.WF_EVENT.DeferEventCtx.phase',
2706: 'Start Phase is '||to_char(wf_event.phase_minthreshold));
2707: end if;
2720: else
2721: p_source_type := lsrc;
2722: end if;
2723:
2724: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2725: wf_log_pkg.string(wf_log_pkg.level_procedure,
2726: 'wf.plsql.WF_EVENT.DeferEventCtx.End',
2727: 'Source Type is '||p_source_type);
2728: end if;
2813: l_parameter_list wf_parameter_list_t := wf_parameter_list_t();
2814: i number := 1;
2815: begin
2816:
2817: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2818: wf_log_pkg.string(wf_log_pkg.level_procedure,
2819: 'wf.plsql.WF_EVENT.raise2.Begin',
2820: 'Event Name:'||p_event_name||' Event Key:'||p_event_key);
2821: end if;
2980:
2981: -- Bug 9370391: tag DB session for BES module
2982: wf_core.tag_db_session(wf_core.conn_tag_bes, p_event_name);
2983:
2984: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2985: wf_log_pkg.string(wf_log_pkg.level_procedure,
2986: 'wf.plsql.WF_EVENT.raise3.Begin',
2987: 'Event Name:'||p_event_name||' Event Key:'||p_event_key ||
2988: 'Maximum nested raise count:'|| wf_event.max_nested_raises||
2997: --In future if we allow the user to set the nested-raises -count
2998: --we could think of restting it to that value instead of zero.
2999: wf_event.nested_raise_count := 0;
3000:
3001: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
3002: wf_log_pkg.string(wf_log_pkg.level_error,
3003: 'wf.plsql.WF_EVENT.raise3.recursion_error',
3004: 'Recursion error raised. Nested raise count exceeded threshold');
3005: end if;
3143:
3144: if (l_agent_obj is not null) then
3145: agent_guid := l_agent_obj.GUID;
3146: else
3147: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
3148: wf_log_pkg.string(wf_log_pkg.level_error,
3149: 'wf.plsql.WF_EVENT.GetSourceAgentGUID.Error',
3150: 'Specified source agent row does '||
3151: 'not exist in database. Setting to NULL.');
3173:
3174: -- bes caching implementation
3175: l_agent_obj wf_agent_obj;
3176: begin
3177: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3178: wf_log_pkg.string(wf_log_pkg.level_procedure,
3179: 'wf.plsql.WF_EVENT.GetAgentDetails.Begin',
3180: 'Get Agent Details');
3181: end if;
3187: if (l_agent_obj is not null) then
3188: l_queue_name := l_agent_obj.QUEUE_NAME;
3189: end if;
3190:
3191: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3192: wf_log_pkg.string(wf_log_pkg.level_statement,
3193: 'wf.plsql.WF_EVENT.GetAgentDetails',
3194: 'l_queue_name = ' || l_queue_name);
3195: end if;
3208: -- if queue_name does not contain schema we will look in WF_SCHEMA
3209: l_owner := wf_event.schema_name;
3210: end if;
3211:
3212: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3213: wf_log_pkg.string(wf_log_pkg.level_statement,
3214: 'wf.plsql.WF_EVENT.GetAgentDetails',
3215: 'l_name = ' || l_name ||
3216: ' l_owner = ' || l_owner);
3238: else
3239: raise no_data_found;
3240: end if;
3241: end if;
3242: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3243: wf_log_pkg.string(wf_log_pkg.level_procedure,
3244: 'wf.plsql.WF_EVENT.GetAgentDetails.END',
3245: 'Get Agent Details');
3246: end if;
3283: AND ((trim(enqueue_enabled) = 'NO') OR (trim(dequeue_enabled) = 'NO'));
3284: */
3285:
3286: begin
3287: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3288: wf_log_pkg.string(wf_log_pkg.level_procedure,
3289: 'wf.plsql.WF_EVENT.StartAgent.Begin',
3290: 'Starting Agents');
3291: end if;
3303: */
3304: -- The agent details must be retrieved even for seeded queue.
3305: GetAgentDetails(agent_name);
3306:
3307: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3308: wf_log_pkg.string(wf_log_pkg.level_statement,
3309: 'wf.plsql.WF_EVENT.StartAgent',
3310: 'dequeue_enabled = ' || WF_EVENT.pv_last_dequeue_enabled);
3311: end if;
3314: -- If the user has disabled the queue for enqueue don't override it.
3315: -- So we only enable the dequeue if dequeue is not enabled and we don't change
3316: -- the current setting of enqueue.
3317:
3318: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3319: wf_log_pkg.string(wf_log_pkg.level_statement,
3320: 'wf.plsql.WF_EVENT.StartAgent',
3321: 'starting queue = ' || wf_event.pv_last_schema_name
3322: || '.' || wf_event.pv_last_agent_name);
3326:
3327: WF_EVENT.pv_last_dequeue_enabled := 'YES';
3328: end if;
3329:
3330: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3331: wf_log_pkg.string(wf_log_pkg.level_procedure,
3332: 'wf.plsql.WF_EVENT.StartAgent.End',
3333: 'Starting Agents');
3334: end if;
3514: , p_navigationThreshold in number)
3515: is
3516: l_api varchar2(100) := g_packName||'setNavigationParams';
3517: begin
3518: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3519: wf_log_pkg.string(wf_log_pkg.level_procedure, l_api,
3520: 'BEGIN agent('||p_agentName||'), navigationThreshold(' ||
3521: p_navigationThreshold||')');
3522: end if;
3536: end if;
3537:
3538: g_processedMessagesCount :=0;
3539:
3540: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3541: wf_log_pkg.string(wf_log_pkg.level_procedure, l_api,
3542: 'END '||getNavigationParams);
3543: end if;
3544: end;
3547: function getQueueNavigation return BINARY_INTEGER is
3548: l_ret BINARY_INTEGER;
3549: l_api varchar2(100) := g_packName||'getQueueNavigation';
3550: begin
3551: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3552: wf_log_pkg.string(wf_log_pkg.level_procedure, l_api,
3553: 'BEGIN '||getNavigationParams);
3554: end if;
3555: if (g_navResetThreshold is null) then -- agent navigation not initialized
3591:
3592: g_processedMessagesCount := g_processedMessagesCount + 1;
3593: g_currentNavigation := l_ret;
3594:
3595: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3596: wf_log_pkg.string(wf_log_pkg.level_procedure, l_api
3597: ,'END return='||getNavigationParams);
3598: end if;
3599: