[Home] [Help]
72: ** if the subscription rule data is MESSAGE
73: */
74: --if (wf_event.test(ename) = 'MESSAGE') then
75:
76: l_event_obj := wf_bes_cache.GetEventByName(ename);
77:
78: if (l_event_obj is null) then
79: wf_core.context('Wf_Event', 'setMessage', ename, ekey);
80: wf_core.raise('WFE_EVENT_NOTEXIST');
300: return true;
301: end if;
302:
303: -- event should be in cache by now
304: l_event_obj := wf_bes_cache.GetEventByName(p_event_name);
305:
306: if (l_event_obj is null) then
307: return false;
308: end if;
336: -- o if the event has a java generate function and a subsequent
337: -- subscription has MESSAGE rule data
338:
339: l_java_defer := false;
340: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name, p_source_type, null);
341:
342: if (l_subs_list is not null) then
343: for i in 1..l_subs_list.COUNT loop
344: l_phase := l_subs_list(i).PHASE;
795: is
796: agt_name varchar2(30);
797: sys_name varchar2(30);
798:
799: -- wf bes cache implementation
800: l_agent_obj wf_agent_obj;
801: begin
802: if (p_agent_guid is null) then
803: return null;
802: if (p_agent_guid is null) then
803: return null;
804: end if;
805:
806: l_agent_obj := wf_bes_cache.GetAgentByGUID(p_agent_guid);
807:
808: if (l_agent_obj is not null) then
809: return wf_agent_t(l_agent_obj.NAME, l_agent_obj.SYSTEM_NAME);
810: else
829: l_subs_list wf_event_subs_tab;
830:
831: begin
832:
833: l_event_obj := wf_bes_cache.GetEventByName(p_event_name);
834:
835: -- if event is not found or no subscriptions to the event, return NONE
836: result := 'NONE';
837: if (l_event_obj is not null) then
834:
835: -- if event is not found or no subscriptions to the event, return NONE
836: result := 'NONE';
837: if (l_event_obj is not null) then
838: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name, 'LOCAL', null);
839:
840: if (l_subs_list is not null) then
841: result := 'KEY';
842: for i in 1..l_subs_list.COUNT loop
867: l_to_type WF_AGENTS.TYPE%TYPE;
868: -- l_mem_agt_name WF_AGENTS.NAME%TYPE;
869: l_to_queue_handler WF_AGENTS.QUEUE_HANDLER%TYPE;
870:
871: -- wf bes cache implementation
872: l_to_agt_obj wf_agent_obj;
873: l_out_agt_obj wf_agent_obj;
874: begin
875: --
911: if (p_event.getFromAgent() is null OR
912: p_event.getFromAgent().getName() is null OR
913: p_event.getFromAgent().getSystem() is null) then
914:
915: l_to_agt_obj := wf_bes_cache.GetAgentByName(toagtname, toagtsys);
916: if (l_to_agt_obj is not null and l_to_agt_obj.STATUS = 'ENABLED') then
917: l_to_type := l_to_agt_obj.TYPE;
918: l_to_queue_handler := l_to_agt_obj.QUEUE_HANDLER;
919: else
930: raise no_data_found;
931: end if;
932: END IF;
933:
934: l_out_agt_obj := wf_bes_cache.GetAgentByQH(l_to_queue_handler, 'OUT');
935:
936: if (l_out_agt_obj is not null and l_out_agt_obj.STATUS = 'ENABLED') then
937: outguid := l_out_agt_obj.GUID;
938: outagtname := l_out_agt_obj.NAME;
981: l_to_protocol WF_AGENTS.PROTOCOL%TYPE;
982: l_to_queue_name WF_AGENTS.QUEUE_NAME%TYPE;
983: l_to_protocol_number NUMBER := 0; -- Hard code as SQLNET
984:
985: -- wf bes cache implementation
986: l_to_agt_obj wf_agent_obj;
987: BEGIN
988:
989: -- MJC: We need to make sure the recipient address is in the correct
998:
999: -- YOHUANG: Different Sql queries for different case to
1000: -- improve performance.
1001:
1002: l_to_agt_obj := wf_bes_cache.GetAgentByName(p_to_agent_name, p_to_system_name);
1003: if (l_to_agt_obj is not null and l_to_agt_obj.STATUS = 'ENABLED') then
1004: l_to_protocol := l_to_agt_obj.PROTOCOL;
1005: l_to_queue_name := l_to_agt_obj.QUEUE_NAME;
1006: else
1081: 'wf.plsql.WF_EVENT.setRecieptList',
1082: 'Setting Recipient List: ' || l_to_agent_name);
1083: end if;
1084:
1085: l_to_agt_obj := wf_bes_cache.GetAgentByName(l_to_agent_name, l_to_system_name);
1086: if (l_to_agt_obj is not null and l_to_agt_obj.STATUS = 'ENABLED') then
1087: l_to_type := l_to_agt_obj.TYPE;
1088: else
1089: raise no_data_found;
1088: else
1089: raise no_data_found;
1090: end if;
1091:
1092: l_out_agt_obj := wf_bes_cache.GetAgentByName(p_out_agent_name, p_out_system_name);
1093: if (l_out_agt_obj is not null and l_out_agt_obj.STATUS = 'ENABLED') then
1094: l_out_queue_handler := l_out_agt_obj.QUEUE_HANDLER;
1095: else
1096: raise no_data_found;
1252: g_local_system_guid := hextoraw(WF_CORE.Translate('WF_SYSTEM_GUID'));
1253: end if;
1254:
1255: -- get the agent information for the local system
1256: l_agent_obj := wf_bes_cache.GetAgentByName(p_agent_name, null);
1257: if (l_agent_obj is not null) then
1258: agt := l_agent_obj.GUID;
1259: dir := upper(l_agent_obj.DIRECTION);
1260: else
1660:
1661: GetAgentDetails(p_agent_name);
1662:
1663: -- get agent details for local system
1664: l_agent_obj := wf_bes_cache.GetAgentByName(p_agent_name, null);
1665: if (l_agent_obj is null) then
1666: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1667: wf_core.raise('WFE_AGENT_NOTEXIST');
1668: end if;
1946: 'wf.plsql.WF_EVENT.dispatch.Begin',
1947: 'Dispatching event '||l_event_name);
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',
2042: l_skip_sub := GetSkippedSub(p_event);
2043:
2044: if (l_skip_sub is not null AND p_source_type = 'LOCAL') then
2045:
2046: l_sub := wf_bes_cache.GetSubscriptionByGUID(l_event_name, l_skip_sub);
2047: if (l_sub is not null) then
2048: res := wf_event.dispatch_internal(p_source_type => l_sub.SOURCE_TYPE,
2049: p_rule_data => l_sub.RULE_DATA,
2050: p_rule_func => trim(l_sub.RULE_FUNCTION),
2063: -- get and dispatch subscriptions to the even only if the event is
2064: -- valid, product is licensed etc. else directly dispatch Any event
2065: if (l_event_obj is not null) then
2066: -- all subscriptions to the event and Any event in the order of phase
2067: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name => l_event_name,
2068: p_source_type => dispatch.p_source_type,
2069: p_source_agent => dispatch.p_source_agent_guid);
2070: -- dispatching all matching subscriptions for the event
2071: if (l_subs_list is not null) then
2101: else
2102:
2103: -- dispatch subscriptions to Any event. this call does not execute the
2104: -- cursor with union all
2105: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name => 'oracle.apps.wf.event.any',
2106: p_source_type => dispatch.p_source_type,
2107: p_source_agent => dispatch.p_source_agent_guid);
2108: -- dispatching all matching subscriptions for Any event
2109: if (l_subs_list is not null) then
2139: -- If no subscriptions dispatched, dispatch subscriptions for Unexpected event.
2140: -- Unexpected event is dispatched only for non-workflow events
2141: if ((not subs_found) and (l_event_name not like 'oracle.apps.wf%')) then
2142:
2143: l_subs_list := wf_bes_cache.GetSubscriptions(p_event_name => 'oracle.apps.wf.event.unexpected',
2144: p_source_type => dispatch.p_source_type,
2145: p_source_agent => dispatch.p_source_agent_guid);
2146: if (l_subs_list is not null) then
2147:
2219: agtname := p_out_agent_override.GetName();
2220: sysname := p_out_agent_override.GetSystem();
2221: end if;
2222:
2223: l_agent_obj := wf_bes_cache.GetAgentByName(agtname, sysname);
2224: if (l_agent_obj is not null) then
2225: qh := l_agent_obj.QUEUE_HANDLER;
2226: end if;
2227:
2276: p_executed boolean;
2277: begin
2278: if (p_queue_handler is null) then
2279: -- get queue details from cache for given agent GUID
2280: l_agent_obj := wf_bes_cache.GetAgentByGUID(p_agent_guid);
2281: if (l_agent_obj is not null) then
2282: qh := l_agent_obj.QUEUE_HANDLER;
2283: end if;
2284: else
2621: end if;
2622:
2623: l_event_name := p_event.GetEventName();
2624: if subguid is not null then
2625: l_sub := wf_bes_cache.GetSubscriptionByGUID(l_event_name, subguid);
2626:
2627: if (l_sub is not null) then
2628: lsrc := l_sub.SOURCE_TYPE;
2629: lphasestart := l_sub.PHASE;
3076: -- bes caching implementation
3077: l_agent_obj wf_agent_obj;
3078: begin
3079:
3080: l_agent_obj := wf_bes_cache.GetAgentByName(agent_name, agent_system);
3081:
3082: if (l_agent_obj is not null) then
3083: agent_guid := l_agent_obj.GUID;
3084: else
3120:
3121: if(agent_name is not null and agent_name <> wf_event.pv_last_agent_name) then
3122: -- for a given agent name Query wf_agents to get the agent info
3123:
3124: l_agent_obj := wf_bes_cache.GetAgentByName(agent_name, null);
3125: if (l_agent_obj is not null) then
3126: l_queue_name := l_agent_obj.QUEUE_NAME;
3127: end if;
3128: