[Home] [Help]
83: func := l_event_obj.GENERATE_FUNCTION;
84:
85: if (func is not null) then
86:
87: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
88: wf_log_pkg.string2(wf_log_pkg.level_statement,
89: 'wf.plsql.wf_event.SetMessage.genfunc_callout',
90: 'Start executing generate function - '||func, true);
91: end if;
114: execute immediate cmd using in out msg, in ename, in ekey;
115: end;
116: end if;
117:
118: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
119: wf_log_pkg.string2(wf_log_pkg.level_statement,
120: 'wf.plsql.wf_event.SetMessage.genfunc_callout',
121: 'End executing generate function - '||func, false);
122: end if;
155: err_msg varchar2(2000);
156: err_stack varchar2(2000);
157: begin
158:
159: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
160: wf_log_pkg.string(wf_log_pkg.level_procedure,
161: 'wf.plsql.WF_EVENT.setErrorInfo.begin',
162: 'Setting Error Info');
163: end if;
190: erragt wf_agent_t;
191: cmd varchar2(1000);
192: begin
193:
194: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
195: wf_log_pkg.string(wf_log_pkg.level_procedure,
196: 'wf.plsql.WF_EVENT.saveErrorToQueue.Begin',
197: 'saving event to WF_ERROR on '|| wf_event.local_system_name);
198: end if;
206:
207: --cmd := 'begin WF_ERROR_QH.enqueue(:v1, :v2); end;';
208: --execute immediate cmd using in p_event,
209: -- in erragt;
210: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
211: wf_log_pkg.string(wf_log_pkg.level_procedure,
212: 'wf.plsql.WF_EVENT.saveErrorToQueue.End',
213: 'error info saved');
214: end if;
229: erragt wf_agent_t;
230: cmd varchar2(1000);
231: begin
232:
233: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
234: wf_log_pkg.string(wf_log_pkg.level_procedure,
235: 'wf.plsql.WF_EVENT.saveErrorToJavaQueue.Begin',
236: 'saving event to WF_JAVA_ERROR on '|| wf_event.local_system_name);
237: end if;
245:
246: --cmd := 'begin WF_ERROR_QH.enqueue(:v1, :v2); end;';
247: --execute immediate cmd using in p_event,
248: -- in erragt;
249: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
250: wf_log_pkg.string(wf_log_pkg.level_procedure,
251: 'wf.plsql.WF_EVENT.saveErrorToJavaQueue.End',
252: 'error info saved');
253: end if;
282: l_phase number;
283: l_rule_func varchar2(240);
284: l_rule_data varchar2(8);
285: begin
286: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
287: wf_log_pkg.string(wf_log_pkg.level_procedure,
288: 'wf.plsql.WF_EVENT.isDeferToJava.begin',
289: 'Checking for Java subscription/generate');
290: end if;
291:
292: if (p_rule_func is not null AND
293: UPPER(substr(p_rule_func, 0, length(java_sub))) = UPPER(java_sub)) then
294: -- this is a Java subscription. Return true
295: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
296: wf_log_pkg.string(wf_log_pkg.level_statement,
297: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
298: 'found a Java subscription');
299: end if;
319:
320: if (l_java_gen AND p_rule_data is not null AND
321: p_rule_data = 'MESSAGE' and p_source_type = 'LOCAL') then
322: -- this is a Java generate function.
323: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
324: wf_log_pkg.string(wf_log_pkg.level_statement,
325: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
326: 'found a Java generate function');
327: end if;
355: end loop;
356: end if;
357:
358: if(l_java_defer) then
359: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
360: wf_log_pkg.string(wf_log_pkg.level_statement,
361: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
362: 'found subsequent Java sub or java generate');
363: end if;
362: 'found subsequent Java sub or java generate');
363: end if;
364: return true;
365: else
366: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
367: wf_log_pkg.string(wf_log_pkg.level_statement,
368: 'wf.plsql.WF_EVENT.isDeferToJava.Subscription',
369: 'No Java sub found or Java Generate Found');
370: end if;
371: return false;
372: end if;
373: end if;
374:
375: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
376: wf_log_pkg.string(wf_log_pkg.level_procedure,
377: 'wf.plsql.WF_EVENT.isDeferToJava.end',
378: 'Checked for Java subscription/generate');
379: end if;
396: p_rule_func in varchar2)
397: return boolean is
398:
399: begin
400: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
401: wf_log_pkg.string(wf_log_pkg.level_procedure,
402: 'wf.plsql.WF_EVENT.isSaveToJavaError.begin',
403: 'Checking Java Error subscription for ' || p_event_name);
404: end if;
405:
406: if (p_rule_func is not null AND
407: UPPER(substr(p_rule_func, 0, length(java_sub))) = UPPER(java_sub)) then
408: -- this is a Java subscription. Return true
409: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
410: wf_log_pkg.string(wf_log_pkg.level_statement,
411: 'wf.plsql.WF_EVENT.isSaveToJavaError.Subscription',
412: 'found a Java subscription');
413: end if;
512: if (wf_event.phase_maxthreshold is not null) AND
513: (p_phase >= wf_event.phase_maxthreshold) AND
514: (p_source_type <> 'ERROR')
515: then
516: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
517: wf_log_pkg.string(wf_log_pkg.level_statement,
518: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
519: 'max threshold reached');
520: end if;
532: p_rule_func);
533: end if;
534:
535: if(defer_to_java OR max_threshold_reached ) then
536: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
537: wf_log_pkg.string(wf_log_pkg.level_statement,
538: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
539: 'detected as deferred');
540: end if;
557: -- So in such case, Value of #CURRENT_PHASE will be used as starting phase.
558: p_event.AddParameterToList('#CURRENT_PHASE', p_phase);
559:
560: if(defer_to_java) then
561: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
562: wf_log_pkg.string(wf_log_pkg.level_statement,
563: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
564: 'deferring to WF_JAVA_DEFERRED');
565: end if;
564: 'deferring to WF_JAVA_DEFERRED');
565: end if;
566: wf_event.DeferEventToJava(p_source_type, p_event);
567: else
568: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
569: wf_log_pkg.string(wf_log_pkg.level_statement,
570: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
571: 'deferring to WF_DEFERRED');
572: end if;
574: end if;
575: res := 'DEFER';
576:
577: elsif (save_to_java_error) then
578: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
579: wf_log_pkg.string(wf_log_pkg.level_statement,
580: 'wf.plsql.WF_EVENT.dispatch_internal.Subscription',
581: 'save to java error queue');
582: end if;
594: begin
595: if (NOT genmsg) AND
596: (p_rule_data = 'MESSAGE') AND
597: (p_source_type = 'LOCAL') then
598: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
599: wf_log_pkg.string(wf_log_pkg.level_statement,
600: 'wf.plsql.WF_EVENT.dispatch_internal.Rule_Data',
601: 'Rule Data is MESSAGE and Source is LOCAL');
602: end if;
604: -- Bug Fix for 4286207
605: begin
606: if (p_event.GetEventData() is null) or
607: (p_event.GetEventData() is not null and dbms_lob.getlength(p_event.GetEventData()) = 0) then
608: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
609: wf_log_pkg.string(wf_log_pkg.level_statement,
610: 'wf.plsql.WF_EVENT.dispatch_internal.generate',
611: 'Need to Generate Message');
612: end if;
615: end if;
616: exception
617: when empty_lob_locator then
618: -- The lob locator is invalid, probably pointing to a empty_clob();
619: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
620: wf_log_pkg.string(wf_log_pkg.level_statement,
621: 'wf.plsql.WF_EVENT.dispatch_internal.generate',
622: 'Invalid Lob Locator Passed, Generate the Message');
623: end if;
659: -- just execute the default dispatch functionality
660: --
661: begin
662:
663: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
664: wf_log_pkg.string2(wf_log_pkg.level_statement,
665: 'wf.plsql.wf_event.dispatch_internal.rulefunc_callout',
666: 'Start executing rule function - '||p_rule_func, true);
667: end if;
683: in out p_event;
684: end if;
685: end if;
686:
687: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
688: wf_log_pkg.string2(wf_log_pkg.level_statement,
689: 'wf.plsql.wf_event.dispatch_internal.rulefunc_callout',
690: 'End executing rule function - '||p_rule_func, false);
691: end if;
710: end if;
711:
712: end;
713:
714: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
715: -- BINDVAR_SCAN_IGNORE[3]
716: wf_log_pkg.string(wf_log_pkg.level_statement,
717: 'wf.plsql.WF_EVENT.dispatch_internal.rule_function',
718: 'Executed Rule Function '||myfunc||' and returned '||res);
721: end if; -- End of "defer_to_java OR max_threshold_reached"
722: else
723: -- Bug 4227307
724: -- Handle the subscriptions that are not eligible for execution.
725: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
726: wf_log_pkg.string(wf_log_pkg.level_statement,
727: 'wf.plsql.wf_event.dispatch_internal.subs_ignore',
728: 'Subscription not executed. Sub Phase='||p_phase||
729: ', Min threshold='||wf_event.phase_minthreshold);
895: outagtname := p_event.getFromAgent().getName();
896: outagtsys := p_event.getFromAgent().getSystem();
897: end if;
898:
899: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
900: wf_log_pkg.string(wf_log_pkg.level_statement,
901: 'wf.plsql.WF_EVENT.Send.info',
902: 'To Agt: '||toagtname||' To Agt Sys:'||toagtsys||
903: 'Out Agt: '||outagtname||' Out Agt Sys:'||outagtsys);
946: if (p_event.getSendDate() is NULL) then
947: p_event.setSendDate(sysdate);
948: end if;
949:
950: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
951: wf_log_pkg.string(wf_log_pkg.level_statement,
952: 'wf.plsql.WF_EVENT.send.enqueue',
953: 'Sending from '||outagtname||' to '||toagtname);
954: end if;
1018: elsif (p_to_system_name <> p_out_system_name) then
1019: l_to_address := l_to_agt_obj.ADDRESS;
1020: end if;
1021:
1022: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1023: wf_log_pkg.string(wf_log_pkg.level_statement,
1024: 'wf.plsql.WF_EVENT.Get_Recipient',
1025: 'Recipient is name: ' || p_to_agent_name ||
1026: ' address: ' || l_to_address || ' protocol: ' ||l_to_protocol);
1075: -- if there is a to queue, we need to set the recipient list address
1076: l_to_agent_name := p_event.getToAgent().getName();
1077: l_to_system_name := p_event.getToAgent().getSystem();
1078:
1079: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1080: wf_log_pkg.string(wf_log_pkg.level_statement,
1081: 'wf.plsql.WF_EVENT.setRecieptList',
1082: 'Setting Recipient List: ' || l_to_agent_name);
1083: end if;
1306: if (wf_event.local_system_status in ('LOCAL','EXTERNAL')) then
1307: if (st = wf_event.local_system_status
1308: OR st = 'ERROR'
1309: OR p_agent_name = 'WF_DEFERRED') then
1310: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1311: wf_log_pkg.string(wf_log_pkg.level_statement,
1312: 'wf.plsql.WF_EVENT.listen.Check1',
1313: 'Source type is equal to system status '||
1314: 'or ERROR or Deferred Processing');
1313: 'Source type is equal to system status '||
1314: 'or ERROR or Deferred Processing');
1315: end if;
1316: else
1317: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1318: wf_log_pkg.string(wf_log_pkg.level_statement,
1319: 'wf.plsql.WF_EVENT.listen.Check2',
1320: 'Source type not valid for current system status');
1321: end if;
1354: else
1355: from_agt_name := evt.getFromAgent().getName();
1356: from_agt_sys := evt.getFromAgent().getSystem();
1357:
1358: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1359: wf_log_pkg.string(wf_log_pkg.level_statement,
1360: 'wf.plsql.WF_EVENT.listen',
1361: 'Event '||evt.getEventName()||
1362: ', hailing from '||from_agt_name||'@'||from_agt_sys||
1394: -- Bug 2210085 - starting a new block to capture exceptions thrown
1395: -- by GetDeferEventCtx
1396: begin
1397: if p_agent_name = 'WF_DEFERRED' then
1398: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1399: wf_log_pkg.string(wf_log_pkg.level_statement,
1400: 'wf.plsql.WF_EVENT.listen.Deferred',
1401: 'Processing Deferred Event');
1402: end if;
1422: exception
1423: when others then
1424: if (wf_event.wf_exception_source = 'RULE') then
1425: if (st = 'ERROR') then
1426: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1427: wf_log_pkg.string(wf_log_pkg.level_error,
1428: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1429: 'Rule Function with Source Error Exception');
1430: end if;
1429: 'Rule Function with Source Error Exception');
1430: end if;
1431: raise;
1432: else
1433: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1434: wf_log_pkg.string(wf_log_pkg.level_error,
1435: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1436: 'Rule Function Error');
1437: end if;
1440: commit;
1441: l_error_count := l_error_count + 1;
1442: end if;
1443: else
1444: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1445: wf_log_pkg.string(wf_log_pkg.level_error,
1446: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1447: 'Non Rule Function Error');
1448: end if;
1461: -- the event again into the error queue.
1462: -- In this case we just rollback the dequeue and raise the
1463: -- exception to the user.
1464: if (( wf_event.wf_exception_source = 'RULE') and (st = 'ERROR')) then
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: 'Error executing Rule Function with Source Type Error');
1469: end if;
1480: wf_core.raise('WFE_UNHANDLED_ERROR');
1481: end if;
1482: elsif (wf_event.wf_exception_source = 'WF') then
1483: -- Bug 4207885: Add the handler of exception with source WF
1484: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1485: wf_log_pkg.string(wf_log_pkg.level_error,
1486: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1487: 'Unexpected Function Error');
1488: end if;
1491: wf_core.token('SQLERRM', sqlerrm);
1492: wf_core.token('SQLCODE', sqlcode);
1493: wf_core.raise('WFE_UNHANDLED_ERROR');
1494: else
1495: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1496: wf_log_pkg.string(wf_log_pkg.level_error,
1497: 'wf.plsql.WF_EVENT.listen.error',
1498: 'GetDeferEventCtx Error');
1499: end if;
1514: wf_event.InitPhaseMinThreshold;
1515: wf_event.SetDispatchMode('SYNC');
1516:
1517: if (p_message_count > 0 AND l_lsn_msg_count >= p_message_count ) then
1518: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1519: wf_log_pkg.string(wf_log_pkg.level_statement,
1520: 'wf.plsql.WF_EVENT.listen.maxMsgCount',
1521: 'Read the specified maximum number of messages');
1522: end if;
1523: exit;
1524: end if;
1525:
1526: if (p_max_error_count > 0 AND l_error_count >= p_max_error_count ) then
1527: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1528: wf_log_pkg.string(wf_log_pkg.level_error,
1529: 'wf.plsql.WF_EVENT.listen.maxErrCount',
1530: 'Encountered the specified maximum number of errors');
1531: end if;
1692:
1693: begin --We will begin processing a transaction (message group).
1694: savepoint trxn_start;
1695:
1696: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1697: wf_log_pkg.string(wf_log_pkg.level_statement,
1698: 'wf.plsql.WF_EVENT.Listen_GRP.processing',
1699: 'Begin processing transaction');
1700: end if;
1706: wf_event.dequeue(agt, evt, qh,p_wait);
1707:
1708: exception
1709: when end_of_transaction then
1710: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
1711: wf_log_pkg.string(wf_log_pkg.level_event,
1712: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1713: 'End of the transaction');
1714: end if;
1729: else
1730: from_agt_name := evt.getFromAgent().getName();
1731: from_agt_sys := evt.getFromAgent().getSystem();
1732:
1733: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1734: wf_log_pkg.string(wf_log_pkg.level_statement,
1735: 'wf.plsql.WF_EVENT.Listen_GRP.event_dequeued',
1736: 'Event '||evt.getEventName()||', hailing from '||from_agt_name||'@'||
1737: from_agt_sys|| ' was dequeued from '|| p_agent_name);
1766: wf_event.dispatch(st, sagt, evt);
1767:
1768: exception
1769: when others then
1770: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1771: wf_log_pkg.string(wf_log_pkg.level_error,
1772: 'wf.plsql.WF_EVENT.Listen_GRP.dispatch_error',
1773: 'Dispatch Error when dispatching Event '||evt.getEventName);
1774: end if;
1791: wf_event.dequeue(agt, evt, qh,p_wait);
1792:
1793: exception
1794: when end_of_transaction then
1795: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
1796: wf_log_pkg.string(wf_log_pkg.level_event,
1797: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1798: 'End of the transaction');
1799: end if;
1822: end loop;
1823:
1824: exception
1825: when end_of_transaction then
1826: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
1827: wf_log_pkg.string(wf_log_pkg.level_event,
1828: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1829: 'End of the transaction after dispatch error');
1830: end if;
1940:
1941: -- Deleting any previous Event parameter indexes.
1942: WF_EVENT.evt_param_index.DELETE;
1943:
1944: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
1945: wf_log_pkg.string(wf_log_pkg.level_procedure,
1946: 'wf.plsql.WF_EVENT.dispatch.Begin',
1947: 'Dispatching event '||l_event_name);
1948: end if;
1948: end if;
1949:
1950: l_event_obj := wf_bes_cache.GetEventByName(l_event_name);
1951: if (l_event_obj is null) then
1952: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1953: wf_log_pkg.string(wf_log_pkg.level_statement,
1954: 'wf.plsql.WF_EVENT.dispatch.no_event',
1955: 'Event is either disabled or product not licensed '||
1956: 'or event not registered');
1972: l_event_obj is not null) then
1973:
1974: if(isDeferToJava(true, l_event_name, p_source_type,
1975: null, null, null)) then
1976: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1977: wf_log_pkg.string(wf_log_pkg.level_statement,
1978: 'wf.plsql.WF_EVENT.dispatch.Defer',
1979: 'Detected as deferred raise. Deferring to ' ||
1980: 'WF_JAVA_DEFERRED');
1980: 'WF_JAVA_DEFERRED');
1981: end if;
1982: wf_event.DeferEventToJava(p_source_type, p_event);
1983: else
1984: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
1985: wf_log_pkg.string(wf_log_pkg.level_statement,
1986: 'wf.plsql.WF_EVENT.dispatch.Defer',
1987: 'Detected as deferred raise. Deferring to ' ||
1988: 'WF_DEFERRED');
2070: -- dispatching all matching subscriptions for the event
2071: if (l_subs_list is not null) then
2072:
2073: for i in 1..l_subs_list.COUNT loop
2074: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2075: wf_log_pkg.string(wf_log_pkg.level_statement,
2076: 'wf.plsql.WF_EVENT.dispatch.Subscriptions',
2077: 'Dispatching '||l_subs_list(i).SOURCE_TYPE||' subscription '||
2078: 'with Phase '||l_subs_list(i).PHASE);
2108: -- dispatching all matching subscriptions for Any event
2109: if (l_subs_list is not null) then
2110:
2111: for i in 1..l_subs_list.COUNT loop
2112: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2113: wf_log_pkg.string(wf_log_pkg.level_statement,
2114: 'wf.plsql.WF_EVENT.dispatch.Any',
2115: 'Dispatching '||l_subs_list(i).SOURCE_TYPE||' subscription '||
2116: 'with Phase '||l_subs_list(i).PHASE);
2145: p_source_agent => dispatch.p_source_agent_guid);
2146: if (l_subs_list is not null) then
2147:
2148: for i in 1..l_subs_list.COUNT loop
2149: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2150: wf_log_pkg.string(wf_log_pkg.level_statement,
2151: 'wf.plsql.WF_EVENT.dispatch.Unexpected',
2152: 'Dispatching '||l_subs_list(i).SOURCE_TYPE||' subscription '||
2153: 'with Phase '||l_subs_list(i).PHASE);
2227:
2228: -- Call the static calls implementation first
2229: p_executed := false;
2230:
2231: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2232: wf_log_pkg.string2(wf_log_pkg.level_statement,
2233: 'wf.plsql.wf_event.enqueue.qhandler_callout',
2234: 'Start executing queue handler - '||qh, true);
2235: end if;
2243: execute immediate cmd using in p_event,
2244: in p_out_agent_override;
2245: end if;
2246:
2247: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2248: wf_log_pkg.string2(wf_log_pkg.level_statement,
2249: 'wf.plsql.wf_event.enqueue.qhandler_callout',
2250: 'End executing queue handler - '||qh, false);
2251: end if;
2292:
2293: -- Call the static calls implementation first
2294: p_executed := false;
2295:
2296: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2297: wf_log_pkg.string2(wf_log_pkg.level_statement,
2298: 'wf.plsql.wf_event.dequeue.qhandler_callout',
2299: 'Start executing queue handler - '||qh, true);
2300: end if;
2308: execute immediate cmd using in p_agent_guid,
2309: out p_event;
2310: end if;
2311:
2312: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2313: wf_log_pkg.string2(wf_log_pkg.level_statement,
2314: 'wf.plsql.wf_event.dequeue.qhandler_callout',
2315: 'End executing queue handler - '||qh, false);
2316: end if;
2419: --while(pos <= myList.COUNT) loop
2420: while(pos is not null) loop
2421: if (myList(pos).getName() = p_Name) then
2422:
2423: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2424: wf_log_pkg.string(wf_log_pkg.level_statement,
2425: 'wf.plsql.WF_EVENT.getValueForParam.get',
2426: 'Name:'||p_Name||' Value:'||myList(pos).getValue());
2427: end if;
2486: defagent wf_agent_t;
2487:
2488: begin
2489:
2490: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2491: wf_log_pkg.string(wf_log_pkg.level_procedure,
2492: 'wf.plsql.WF_EVENT.DeferEvent.Begin',
2493: 'Deferring Event: '||p_event.getEventName());
2494: end if;
2503: -- Deferred Agent/System into the message for
2504: -- reference when we process the event
2505: --
2506: if p_source_type = 'LOCAL' then
2507: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2508: wf_log_pkg.string(wf_log_pkg.level_statement,
2509: 'wf.plsql.WF_EVENT.DeferEvent.Local',
2510: 'Detected as Local, setting From Agent:'||
2511: 'WF_DEFERRED@'||wf_event.local_system_name);
2515:
2516: --
2517: -- Enqueue onto the deferred agent
2518: --
2519: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2520: wf_log_pkg.string(wf_log_pkg.level_statement,
2521: 'wf.plsql.WF_EVENT.DeferEvent.done',
2522: 'Enqueuing on Deferred Queue');
2523: end if;
2539: is
2540: defagent wf_agent_t;
2541:
2542: begin
2543: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2544: wf_log_pkg.string(wf_log_pkg.level_procedure,
2545: 'wf.plsql.WF_EVENT.DeferEventToJava.Begin',
2546: 'Deferring Event: '|| p_event.getEventName());
2547: end if;
2555: -- Deferred Agent/System into the message for
2556: -- reference when we process the event
2557: --
2558: if p_source_type = 'LOCAL' then
2559: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2560: wf_log_pkg.string(wf_log_pkg.level_statement,
2561: 'wf.plsql.WF_EVENT.DeferEventToJava.Local',
2562: 'Detected as Local, setting From Agent:'||
2563: 'WF_JAVA_DEFERRED@'|| wf_event.local_system_name);
2574: -- directly invoke enqueue on the PL/SQL queue handler
2575: --
2576: wf_event_ojmstext_qh.enqueue(p_event, defagent);
2577:
2578: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2579: wf_log_pkg.string(wf_log_pkg.level_statement,
2580: 'wf.plsql.WF_EVENT.DeferEventToJava.done',
2581: 'Enqueuing on Java Deferred Queue');
2582: end if;
2604: l_sub wf_event_subs_obj;
2605: l_event_name varchar2(240);
2606: begin
2607:
2608: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2609: wf_log_pkg.string(wf_log_pkg.level_procedure,
2610: 'wf.plsql.WF_EVENT.DeferEventCtx.Begin',
2611: 'Getting Defer Event Ctx');
2612: end if;
2613: --
2614: -- Determine the Start Phase, and sourec type
2615: --
2616: subguid := p_event.Error_Subscription;
2617: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2618: wf_log_pkg.string(wf_log_pkg.level_statement,
2619: 'wf.plsql.WF_EVENT.DeferEventCtx.sub_guid',
2620: 'Sub Guid is '||subguid);
2621: end if;
2641: else
2642: wf_event.phase_minthreshold := 0; -- for deferred raise
2643: end if;
2644:
2645: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
2646: wf_log_pkg.string(wf_log_pkg.level_statement,
2647: 'wf.plsql.WF_EVENT.DeferEventCtx.phase',
2648: 'Start Phase is '||to_char(wf_event.phase_minthreshold));
2649: end if;
2662: else
2663: p_source_type := lsrc;
2664: end if;
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.End',
2669: 'Source Type is '||p_source_type);
2670: end if;
2755: l_parameter_list wf_parameter_list_t := wf_parameter_list_t();
2756: i number := 1;
2757: begin
2758:
2759: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2760: wf_log_pkg.string(wf_log_pkg.level_procedure,
2761: 'wf.plsql.WF_EVENT.raise2.Begin',
2762: 'Event Name:'||p_event_name||' Event Key:'||p_event_key);
2763: end if;
2919: o_value varchar2(200);
2920: event wf_event_t;
2921: begin
2922:
2923: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2924: wf_log_pkg.string(wf_log_pkg.level_procedure,
2925: 'wf.plsql.WF_EVENT.raise3.Begin',
2926: 'Event Name:'||p_event_name||' Event Key:'||p_event_key ||
2927: 'Maximum nested raise count:'|| wf_event.max_nested_raises||
2936: --In future if we allow the user to set the nested-raises -count
2937: --we could think of restting it to that value instead of zero.
2938: wf_event.nested_raise_count := 0;
2939:
2940: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
2941: wf_log_pkg.string(wf_log_pkg.level_error,
2942: 'wf.plsql.WF_EVENT.raise3.recursion_error',
2943: 'Recursion error raised. Nested raise count exceeded threshold');
2944: end if;
3081:
3082: if (l_agent_obj is not null) then
3083: agent_guid := l_agent_obj.GUID;
3084: else
3085: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
3086: wf_log_pkg.string(wf_log_pkg.level_error,
3087: 'wf.plsql.WF_EVENT.GetSourceAgentGUID.Error',
3088: 'Specified source agent row does '||
3089: 'not exist in database. Setting to NULL.');
3111:
3112: -- bes caching implementation
3113: l_agent_obj wf_agent_obj;
3114: begin
3115: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3116: wf_log_pkg.string(wf_log_pkg.level_procedure,
3117: 'wf.plsql.WF_EVENT.GetAgentDetails.Begin',
3118: 'Get Agent Details');
3119: end if;
3125: if (l_agent_obj is not null) then
3126: l_queue_name := l_agent_obj.QUEUE_NAME;
3127: end if;
3128:
3129: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3130: wf_log_pkg.string(wf_log_pkg.level_statement,
3131: 'wf.plsql.WF_EVENT.GetAgentDetails',
3132: 'l_queue_name = ' || l_queue_name);
3133: end if;
3146: -- if queue_name does not contain schema we will look in WF_SCHEMA
3147: l_owner := wf_event.schema_name;
3148: end if;
3149:
3150: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3151: wf_log_pkg.string(wf_log_pkg.level_statement,
3152: 'wf.plsql.WF_EVENT.GetAgentDetails',
3153: 'l_name = ' || l_name ||
3154: ' l_owner = ' || l_owner);
3176: else
3177: raise no_data_found;
3178: end if;
3179: end if;
3180: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3181: wf_log_pkg.string(wf_log_pkg.level_procedure,
3182: 'wf.plsql.WF_EVENT.GetAgentDetails.END',
3183: 'Get Agent Details');
3184: end if;
3221: AND ((trim(enqueue_enabled) = 'NO') OR (trim(dequeue_enabled) = 'NO'));
3222: */
3223:
3224: begin
3225: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3226: wf_log_pkg.string(wf_log_pkg.level_procedure,
3227: 'wf.plsql.WF_EVENT.StartAgent.Begin',
3228: 'Starting Agents');
3229: end if;
3241: */
3242: -- The agent details must be retrieved even for seeded queue.
3243: GetAgentDetails(agent_name);
3244:
3245: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3246: wf_log_pkg.string(wf_log_pkg.level_statement,
3247: 'wf.plsql.WF_EVENT.StartAgent',
3248: 'dequeue_enabled = ' || WF_EVENT.pv_last_dequeue_enabled);
3249: end if;
3252: -- If the user has disabled the queue for enqueue don't override it.
3253: -- So we only enable the dequeue if dequeue is not enabled and we don't change
3254: -- the current setting of enqueue.
3255:
3256: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
3257: wf_log_pkg.string(wf_log_pkg.level_statement,
3258: 'wf.plsql.WF_EVENT.StartAgent',
3259: 'starting queue = ' || wf_event.pv_last_schema_name
3260: || '.' || wf_event.pv_last_agent_name);
3264:
3265: WF_EVENT.pv_last_dequeue_enabled := 'YES';
3266: end if;
3267:
3268: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
3269: wf_log_pkg.string(wf_log_pkg.level_procedure,
3270: 'wf.plsql.WF_EVENT.StartAgent.End',
3271: 'Starting Agents');
3272: end if;