[Home] [Help]
89: ** if the subscription rule data is MESSAGE
90: */
91: --if (wf_event.test(ename) = 'MESSAGE') then
92:
93: l_event_obj := wf_bes_cache.GetEventByName(ename);
94:
95: if (l_event_obj is null) then
96: wf_core.context('Wf_Event', 'setMessage', ename, ekey);
97: wf_core.raise('WFE_EVENT_NOTEXIST');
317: return true;
318: end if;
319:
320: -- event should be in cache by now
321: l_event_obj := wf_bes_cache.GetEventByName(p_event_name);
322:
323: if (l_event_obj is null) then
324: return false;
325: end if;
353: -- o if the event has a java generate function and a subsequent
354: -- subscription has MESSAGE rule data
355:
356: l_java_defer := false;
357: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name, p_source_type, null);
358:
359: if (l_subs_list is not null) then
360: for i in 1..l_subs_list.COUNT loop
361: l_phase := l_subs_list(i).PHASE;
825: is
826: agt_name varchar2(30);
827: sys_name varchar2(30);
828:
829: -- wf bes cache implementation
830: l_agent_obj wf_agent_obj;
831: begin
832: if (p_agent_guid is null) then
833: return null;
832: if (p_agent_guid is null) then
833: return null;
834: end if;
835:
836: l_agent_obj := wf_bes_cache.GetAgentByGUID(p_agent_guid);
837:
838: if (l_agent_obj is not null) then
839: return wf_agent_t(l_agent_obj.NAME, l_agent_obj.SYSTEM_NAME);
840: else
859: l_subs_list wf_event_subs_tab;
860:
861: begin
862:
863: l_event_obj := wf_bes_cache.GetEventByName(p_event_name);
864:
865: -- if event is not found or no subscriptions to the event, return NONE
866: result := 'NONE';
867: if (l_event_obj is not null) then
864:
865: -- if event is not found or no subscriptions to the event, return NONE
866: result := 'NONE';
867: if (l_event_obj is not null) then
868: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name, 'LOCAL', null);
869:
870: if (l_subs_list is not null) then
871: result := 'KEY';
872: for i in 1..l_subs_list.COUNT loop
897: l_to_type WF_AGENTS.TYPE%TYPE;
898: -- l_mem_agt_name WF_AGENTS.NAME%TYPE;
899: l_to_queue_handler WF_AGENTS.QUEUE_HANDLER%TYPE;
900:
901: -- wf bes cache implementation
902: l_to_agt_obj wf_agent_obj;
903: l_out_agt_obj wf_agent_obj;
904: begin
905: --
941: if (p_event.getFromAgent() is null OR
942: p_event.getFromAgent().getName() is null OR
943: p_event.getFromAgent().getSystem() is null) then
944:
945: l_to_agt_obj := wf_bes_cache.GetAgentByName(toagtname, toagtsys);
946: if (l_to_agt_obj is not null and l_to_agt_obj.STATUS = 'ENABLED') then
947: l_to_type := l_to_agt_obj.TYPE;
948: l_to_queue_handler := l_to_agt_obj.QUEUE_HANDLER;
949: else
960: raise no_data_found;
961: end if;
962: END IF;
963:
964: l_out_agt_obj := wf_bes_cache.GetAgentByQH(l_to_queue_handler, 'OUT');
965:
966: if (l_out_agt_obj is not null and l_out_agt_obj.STATUS = 'ENABLED') then
967: outguid := l_out_agt_obj.GUID;
968: outagtname := l_out_agt_obj.NAME;
1011: l_to_protocol WF_AGENTS.PROTOCOL%TYPE;
1012: l_to_queue_name WF_AGENTS.QUEUE_NAME%TYPE;
1013: l_to_protocol_number NUMBER := 0; -- Hard code as SQLNET
1014:
1015: -- wf bes cache implementation
1016: l_to_agt_obj wf_agent_obj;
1017: BEGIN
1018:
1019: -- MJC: We need to make sure the recipient address is in the correct
1028:
1029: -- YOHUANG: Different Sql queries for different case to
1030: -- improve performance.
1031:
1032: l_to_agt_obj := wf_bes_cache.GetAgentByName(p_to_agent_name, p_to_system_name);
1033: if (l_to_agt_obj is not null and l_to_agt_obj.STATUS = 'ENABLED') then
1034: l_to_protocol := l_to_agt_obj.PROTOCOL;
1035: l_to_queue_name := l_to_agt_obj.QUEUE_NAME;
1036: else
1111: 'wf.plsql.WF_EVENT.setRecieptList',
1112: 'Setting Recipient List: ' || l_to_agent_name);
1113: end if;
1114:
1115: l_to_agt_obj := wf_bes_cache.GetAgentByName(l_to_agent_name, l_to_system_name);
1116: if (l_to_agt_obj is not null and l_to_agt_obj.STATUS = 'ENABLED') then
1117: l_to_type := l_to_agt_obj.TYPE;
1118: else
1119: raise no_data_found;
1118: else
1119: raise no_data_found;
1120: end if;
1121:
1122: l_out_agt_obj := wf_bes_cache.GetAgentByName(p_out_agent_name, p_out_system_name);
1123: if (l_out_agt_obj is not null and l_out_agt_obj.STATUS = 'ENABLED') then
1124: l_out_queue_handler := l_out_agt_obj.QUEUE_HANDLER;
1125: else
1126: raise no_data_found;
1280: g_local_system_guid := hextoraw(WF_CORE.Translate('WF_SYSTEM_GUID'));
1281: end if;
1282:
1283: -- get the agent information for the local system
1284: l_agent_obj := wf_bes_cache.GetAgentByName(p_agent_name, null);
1285: if (l_agent_obj is not null) then
1286: agt := l_agent_obj.GUID;
1287: dir := upper(l_agent_obj.DIRECTION);
1288: else
1701:
1702: GetAgentDetails(p_agent_name);
1703:
1704: -- get agent details for local system
1705: l_agent_obj := wf_bes_cache.GetAgentByName(p_agent_name, null);
1706: if (l_agent_obj is null) then
1707: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1708: wf_core.raise('WFE_AGENT_NOTEXIST');
1709: end if;
2003: 'wf.plsql.WF_EVENT.dispatch.Begin',
2004: 'Dispatching event '||l_event_name);
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',
2099: l_skip_sub := GetSkippedSub(p_event);
2100:
2101: if (l_skip_sub is not null AND p_source_type = 'LOCAL') then
2102:
2103: l_sub := wf_bes_cache.GetSubscriptionByGUID(l_event_name, l_skip_sub);
2104: if (l_sub is not null) then
2105: res := wf_event.dispatch_internal(p_source_type => l_sub.SOURCE_TYPE,
2106: p_rule_data => l_sub.RULE_DATA,
2107: p_rule_func => trim(l_sub.RULE_FUNCTION),
2120: -- get and dispatch subscriptions to the even only if the event is
2121: -- valid, product is licensed etc. else directly dispatch Any event
2122: if (l_event_obj is not null) then
2123: -- all subscriptions to the event and Any event in the order of phase
2124: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name => l_event_name,
2125: p_source_type => dispatch.p_source_type,
2126: p_source_agent => dispatch.p_source_agent_guid);
2127: -- dispatching all matching subscriptions for the event
2128: if (l_subs_list is not null) then
2158: else
2159:
2160: -- dispatch subscriptions to Any event. this call does not execute the
2161: -- cursor with union all
2162: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name => 'oracle.apps.wf.event.any',
2163: p_source_type => dispatch.p_source_type,
2164: p_source_agent => dispatch.p_source_agent_guid);
2165: -- dispatching all matching subscriptions for Any event
2166: if (l_subs_list is not null) then
2196: -- If no subscriptions dispatched, dispatch subscriptions for Unexpected event.
2197: -- Unexpected event is dispatched only for non-workflow events
2198: if ((not subs_found) and (l_event_name not like 'oracle.apps.wf%')) then
2199:
2200: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name => 'oracle.apps.wf.event.unexpected',
2201: p_source_type => dispatch.p_source_type,
2202: p_source_agent => dispatch.p_source_agent_guid);
2203: if (l_subs_list is not null) then
2204:
2276: agtname := p_out_agent_override.GetName();
2277: sysname := p_out_agent_override.GetSystem();
2278: end if;
2279:
2280: l_agent_obj := wf_bes_cache.GetAgentByName(agtname, sysname);
2281: if (l_agent_obj is not null) then
2282: qh := l_agent_obj.QUEUE_HANDLER;
2283: end if;
2284:
2333: p_executed boolean;
2334: begin
2335: if (p_queue_handler is null) then
2336: -- get queue details from cache for given agent GUID
2337: l_agent_obj := wf_bes_cache.GetAgentByGUID(p_agent_guid);
2338: if (l_agent_obj is not null) then
2339: qh := l_agent_obj.QUEUE_HANDLER;
2340: end if;
2341: else
2679: end if;
2680:
2681: l_event_name := p_event.GetEventName();
2682: if subguid is not null then
2683: l_sub := wf_bes_cache.GetSubscriptionByGUID(l_event_name, subguid);
2684:
2685: if (l_sub is not null) then
2686: lsrc := l_sub.SOURCE_TYPE;
2687: lphasestart := l_sub.PHASE;
3138: -- bes caching implementation
3139: l_agent_obj wf_agent_obj;
3140: begin
3141:
3142: l_agent_obj := wf_bes_cache.GetAgentByName(agent_name, agent_system);
3143:
3144: if (l_agent_obj is not null) then
3145: agent_guid := l_agent_obj.GUID;
3146: else
3182:
3183: if(agent_name is not null and agent_name <> wf_event.pv_last_agent_name) then
3184: -- for a given agent name Query wf_agents to get the agent info
3185:
3186: l_agent_obj := wf_bes_cache.GetAgentByName(agent_name, null);
3187: if (l_agent_obj is not null) then
3188: l_queue_name := l_agent_obj.QUEUE_NAME;
3189: end if;
3190: