eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.WF_EVENT_SUBSCRIPTIONS_PKG dependencies on WF_EVENT

Line 1: package body WF_EVENT_SUBSCRIPTIONS_PKG as

1: package body WF_EVENT_SUBSCRIPTIONS_PKG as
2: /* $Header: WFEVSUBB.pls 120.8 2011/04/26 19:36:59 vshanmug ship $ */
3: m_table_name varchar2(255) := 'WF_EVENT_SUBSCRIPTIONS';
4: m_package_version varchar2(30) := '1.0';
5:

Line 3: m_table_name varchar2(255) := 'WF_EVENT_SUBSCRIPTIONS';

1: package body WF_EVENT_SUBSCRIPTIONS_PKG as
2: /* $Header: WFEVSUBB.pls 120.8 2011/04/26 19:36:59 vshanmug ship $ */
3: m_table_name varchar2(255) := 'WF_EVENT_SUBSCRIPTIONS';
4: m_package_version varchar2(30) := '1.0';
5:
6:
7: procedure validate_subscription (X_EVENT_FILTER_GUID in raw,

Line 63: cursor C is select ROWID from wf_event_subscriptions where guid = x_guid;

59: ) is
60:
61: l_guid raw(16);
62: l_event_name varchar2(240);
63: cursor C is select ROWID from wf_event_subscriptions where guid = x_guid;
64: l_licensed_flag varchar2(1);
65: l_rule_func varchar2(240);
66: begin
67: validate_subscription (X_EVENT_FILTER_GUID,

Line 71: l_licensed_flag := WF_EVENTS_PKG.is_product_licensed (X_OWNER_TAG);

67: validate_subscription (X_EVENT_FILTER_GUID,
68: X_CUSTOMIZATION_LEVEL,
69: X_STATUS); -- Bug 2756800
70:
71: l_licensed_flag := WF_EVENTS_PKG.is_product_licensed (X_OWNER_TAG);
72: if (X_RULE_FUNCTION is null and X_JAVA_RULE_FUNC is null) then
73: l_rule_func := 'WF_RULE.DEFAULT_RULE';
74: elsif (x_rule_function is not null) then
75: l_rule_func := x_rule_function;

Line 100: FROM wf_events

96: -- Throw an error to the UI.
97: begin
98: SELECT name
99: INTO l_event_name
100: FROM wf_events
101: WHERE guid = x_event_filter_guid;
102: exception
103: when no_data_found then
104: null;

Line 113: insert into wf_event_subscriptions (

109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
111: Wf_Core.Raise('WFE_DUPLICATE_SUB');
112: else
113: insert into wf_event_subscriptions (
114: guid,
115: system_guid,
116: source_type,
117: source_agent_guid,

Line 170: from wf_event_subscriptions

166: X_STANDARD_CODE,
167: X_STANDARD_TYPE
168: from dual where not exists (
169: select 'duplicate'
170: from wf_event_subscriptions
171: where guid = X_GUID);
172: end if;
173:
174: open c;

Line 180: wf_event.raise('oracle.apps.wf.event.subscription.create', x_guid);

176: if (c%notfound) then
177: close c;
178: raise no_data_found;
179: else
180: wf_event.raise('oracle.apps.wf.event.subscription.create', x_guid);
181: end if;
182: close c;
183:
184: exception

Line 186: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Insert_Row', x_guid,

182: close c;
183:
184: exception
185: when others then
186: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Insert_Row', x_guid,
187: x_system_guid, X_SOURCE_TYPE, X_SOURCE_AGENT_GUID);
188: raise;
189:
190: end INSERT_ROW;

Line 233: l_licensed_flag := WF_EVENTS_PKG.is_product_licensed (X_OWNER_TAG);

229: validate_subscription (X_EVENT_FILTER_GUID,
230: X_CUSTOMIZATION_LEVEL,
231: X_STATUS); -- Bug 2756800
232:
233: l_licensed_flag := WF_EVENTS_PKG.is_product_licensed (X_OWNER_TAG);
234: if (X_RULE_FUNCTION is null and X_JAVA_RULE_FUNC is null) then
235: l_rule_func := 'WF_RULE.DEFAULT_RULE';
236: elsif (x_rule_function is not null) then
237: l_rule_func := x_rule_function;

Line 262: FROM wf_events

258: -- Throw an error to the UI.
259: begin
260: SELECT name
261: INTO l_event_name
262: FROM wf_events
263: WHERE guid = x_event_filter_guid;
264: exception
265: when no_data_found then
266: null;

Line 268: Wf_Core.Context('Wf_Event_Subscriptions_Pkg', 'Update_Row');

264: exception
265: when no_data_found then
266: null;
267: end;
268: Wf_Core.Context('Wf_Event_Subscriptions_Pkg', 'Update_Row');
269: Wf_Core.Token('EVENT', l_event_name);
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);

Line 277: if WF_EVENTS_PKG.g_Mode = 'FORCE' then

273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
276:
277: if WF_EVENTS_PKG.g_Mode = 'FORCE' then
278: update wf_event_subscriptions set
279: system_guid = X_SYSTEM_GUID,
280: source_type = X_SOURCE_TYPE,
281: source_agent_guid = X_SOURCE_AGENT_GUID,

Line 278: update wf_event_subscriptions set

274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
276:
277: if WF_EVENTS_PKG.g_Mode = 'FORCE' then
278: update wf_event_subscriptions set
279: system_guid = X_SYSTEM_GUID,
280: source_type = X_SOURCE_TYPE,
281: source_agent_guid = X_SOURCE_AGENT_GUID,
282: event_filter_guid = X_EVENT_FILTER_GUID,

Line 310: wf_event.raise('oracle.apps.wf.event.subscription.update', X_GUID);

306:
307: if (sql%notfound) then
308: raise no_data_found;
309: else
310: wf_event.raise('oracle.apps.wf.event.subscription.update', X_GUID);
311: end if;
312:
313: else
314: -- User logged in is not seed

Line 316: l_update_allowed := WF_EVENTS_PKG.is_update_allowed(X_CUSTOMIZATION_LEVEL, l_custom_level);

312:
313: else
314: -- User logged in is not seed
315: fetch_custom_level(X_GUID, l_custom_level);
316: l_update_allowed := WF_EVENTS_PKG.is_update_allowed(X_CUSTOMIZATION_LEVEL, l_custom_level);
317:
318: if l_update_allowed = 'N' then
319: -- Set up the Error Stack
320: wf_core.context('WF_EVENT_SUBSCRIPTIONS_PKG','UPDATE_ROW',

Line 320: wf_core.context('WF_EVENT_SUBSCRIPTIONS_PKG','UPDATE_ROW',

316: l_update_allowed := WF_EVENTS_PKG.is_update_allowed(X_CUSTOMIZATION_LEVEL, l_custom_level);
317:
318: if l_update_allowed = 'N' then
319: -- Set up the Error Stack
320: wf_core.context('WF_EVENT_SUBSCRIPTIONS_PKG','UPDATE_ROW',
321: X_EVENT_FILTER_GUID,
322: l_custom_level,
323: X_CUSTOMIZATION_LEVEL);
324: return;

Line 328: if WF_EVENTS_PKG.g_Mode = 'UPGRADE' then

324: return;
325: end if;
326:
327: if X_CUSTOMIZATION_LEVEL = 'C'then
328: if WF_EVENTS_PKG.g_Mode = 'UPGRADE' then
329: -- Here are the updates allowed when the caller is the Loader
330: update wf_event_subscriptions set
331: system_guid = X_SYSTEM_GUID,
332: source_type = X_SOURCE_TYPE,

Line 330: update wf_event_subscriptions set

326:
327: if X_CUSTOMIZATION_LEVEL = 'C'then
328: if WF_EVENTS_PKG.g_Mode = 'UPGRADE' then
329: -- Here are the updates allowed when the caller is the Loader
330: update wf_event_subscriptions set
331: system_guid = X_SYSTEM_GUID,
332: source_type = X_SOURCE_TYPE,
333: source_agent_guid = X_SOURCE_AGENT_GUID,
334: event_filter_guid = X_EVENT_FILTER_GUID,

Line 365: update wf_event_subscriptions

361: -- UI users cannot update Core events
362: null;
363: -- vshanmug - Expression is temporarily used to store custom ws-security settings
364: -- expression column is not used in BES
365: update wf_event_subscriptions
366: set expression = X_EXPRESSION
367: where guid = X_GUID;
368:
369: l_raise_event_flag := 'Y';

Line 373: if WF_EVENTS_PKG.g_Mode = 'UPGRADE' then

369: l_raise_event_flag := 'Y';
370:
371: end if;
372: elsif X_CUSTOMIZATION_LEVEL = 'L' then
373: if WF_EVENTS_PKG.g_Mode = 'UPGRADE' then
374: -- Limit events can have only a status change..
375: -- When the loader is loading the events the
376: -- users changes must be preserved. Update all
377: -- fields EXCEPT the status field.

Line 378: update wf_event_subscriptions set

374: -- Limit events can have only a status change..
375: -- When the loader is loading the events the
376: -- users changes must be preserved. Update all
377: -- fields EXCEPT the status field.
378: update wf_event_subscriptions set
379: system_guid = X_SYSTEM_GUID,
380: source_type = X_SOURCE_TYPE,
381: source_agent_guid = X_SOURCE_AGENT_GUID,
382: event_filter_guid = X_EVENT_FILTER_GUID,

Line 415: update wf_event_subscriptions set

411: -- Updates are allowed ONLY to the status field.
412:
413: -- vshanmug - Expression is temporarily used to store custom ws-security settings
414: -- expression column is not used in BES
415: update wf_event_subscriptions set
416: status = X_STATUS,
417: licensed_flag = l_licensed_flag,
418: expression = X_EXPRESSION
419: where guid = X_GUID;

Line 429: if WF_EVENTS_PKG.g_Mode = 'CUSTOM' then

425: elsif X_CUSTOMIZATION_LEVEL = 'U' then
426: -- Here are the updates allowed for extensible and User defined events
427: -- only when the caller is the UI
428:
429: if WF_EVENTS_PKG.g_Mode = 'CUSTOM' then
430: update wf_event_subscriptions set
431: system_guid = X_SYSTEM_GUID,
432: source_type = X_SOURCE_TYPE,
433: source_agent_guid = X_SOURCE_AGENT_GUID,

Line 430: update wf_event_subscriptions set

426: -- Here are the updates allowed for extensible and User defined events
427: -- only when the caller is the UI
428:
429: if WF_EVENTS_PKG.g_Mode = 'CUSTOM' then
430: update wf_event_subscriptions set
431: system_guid = X_SYSTEM_GUID,
432: source_type = X_SOURCE_TYPE,
433: source_agent_guid = X_SOURCE_AGENT_GUID,
434: event_filter_guid = X_EVENT_FILTER_GUID,

Line 475: wf_event.raise('oracle.apps.wf.event.subscription.update', X_GUID);

471:
472: -- Only raise if all if no raise_event_flag is set to 'Y'
473: -- fetch_custom_level will raise no_data_found if the subscription is not found
474: if (l_raise_event_flag = 'Y') then
475: wf_event.raise('oracle.apps.wf.event.subscription.update', X_GUID);
476: end if;
477:
478: end if;
479:

Line 516: WF_EVENT_SUBSCRIPTIONS_PKG.UPDATE_ROW (

512: ) is
513: row_id varchar2(64);
514: begin
515: begin
516: WF_EVENT_SUBSCRIPTIONS_PKG.UPDATE_ROW (
517: X_GUID => X_GUID,
518: X_SYSTEM_GUID => X_SYSTEM_GUID,
519: X_SOURCE_TYPE => X_SOURCE_TYPE,
520: X_SOURCE_AGENT_GUID => X_SOURCE_AGENT_GUID,

Line 547: WF_EVENT_SUBSCRIPTIONS_PKG.INSERT_ROW(

543: X_STANDARD_TYPE => X_STANDARD_TYPE
544: );
545: exception
546: when no_data_found then
547: WF_EVENT_SUBSCRIPTIONS_PKG.INSERT_ROW(
548: X_ROWID => row_id,
549: X_GUID => X_GUID,
550: X_SYSTEM_GUID => X_SYSTEM_GUID,
551: X_SOURCE_TYPE => X_SOURCE_TYPE,

Line 583: wf_core.context('Wf_Event_Subscriptions_Pkg', 'Load_Row', x_guid,

579: -- Invalidate cache
580: wf_bes_cache.SetMetaDataUploaded();
581: exception
582: when others then
583: wf_core.context('Wf_Event_Subscriptions_Pkg', 'Load_Row', x_guid,
584: x_source_type, X_SOURCE_AGENT_GUID);
585: raise;
586: end LOAD_ROW;
587: -----------------------------------------------------------------------------

Line 590: wf_event.raise('oracle.apps.wf.event.subscription.delete',x_guid);

586: end LOAD_ROW;
587: -----------------------------------------------------------------------------
588: procedure DELETE_ROW (X_GUID in raw) is
589: begin
590: wf_event.raise('oracle.apps.wf.event.subscription.delete',x_guid);
591:
592: delete from wf_event_subscriptions
593: where guid = X_GUID;
594:

Line 592: delete from wf_event_subscriptions

588: procedure DELETE_ROW (X_GUID in raw) is
589: begin
590: wf_event.raise('oracle.apps.wf.event.subscription.delete',x_guid);
591:
592: delete from wf_event_subscriptions
593: where guid = X_GUID;
594:
595: if (sql%notfound) then
596: raise no_data_found;

Line 603: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Row', x_guid);

599: -- Invalidate cache
600: wf_bes_cache.SetMetaDataUploaded();
601: exception
602: when others then
603: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Row', x_guid);
604: raise;
605: end DELETE_ROW;
606: ----------------------------------------------------------------------------
607: procedure DELETE_SET (

Line 634: delete from wf_event_subscriptions

630: X_STANDARD_CODE in varchar2,
631: X_STANDARD_TYPE in varchar2
632: ) is
633: begin
634: delete from wf_event_subscriptions
635: where (X_SYSTEM_GUID is null or (X_SYSTEM_GUID is not null
636: and system_guid like X_SYSTEM_GUID))
637: and (X_SOURCE_TYPE is null or (X_SOURCE_TYPE is not null
638: and source_type like X_SOURCE_TYPE))

Line 688: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Set',

684: -- Invalidate cache
685: wf_bes_cache.SetMetaDataUploaded();
686: exception
687: when others then
688: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Set',
689: x_system_guid, X_source_type, X_Event_Filter_GUID);
690: raise;
691: end DELETE_SET;
692: ----------------------------------------------------------------------------

Line 750: from wf_event_subscriptions s, wf_events e

746: l_rule_function, l_wf_process_type, l_wf_process_name,
747: l_parameters, l_owner_name, l_owner_tag, l_description, l_expression,
748: l_customization_level, l_licensed_flag,l_standardtype,l_standardcode,
749: l_javarulefunc,l_onerror , l_actioncode
750: from wf_event_subscriptions s, wf_events e
751: where s.guid = x_guid
752: and e.guid = s.event_filter_guid;
753:
754: l_doc := xmldom.newDOMDocument;

Line 756: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);

752: and e.guid = s.event_filter_guid;
753:
754: l_doc := xmldom.newDOMDocument;
755: l_root := xmldom.makeNode(l_doc);
756: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
757: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
758: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
759: m_package_version);
760: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',

Line 757: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);

753:
754: l_doc := xmldom.newDOMDocument;
755: l_root := xmldom.makeNode(l_doc);
756: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
757: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
758: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
759: m_package_version);
760: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
761: rawtohex(x_guid));

Line 758: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,

754: l_doc := xmldom.newDOMDocument;
755: l_root := xmldom.makeNode(l_doc);
756: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
757: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
758: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
759: m_package_version);
760: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
761: rawtohex(x_guid));
762: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',

Line 760: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',

756: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
757: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
758: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
759: m_package_version);
760: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
761: rawtohex(x_guid));
762: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
763: rawtohex(l_system_guid));
764: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',

Line 762: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',

758: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
759: m_package_version);
760: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
761: rawtohex(x_guid));
762: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
763: rawtohex(l_system_guid));
764: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
765: l_source_type);
766: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',

Line 764: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',

760: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
761: rawtohex(x_guid));
762: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
763: rawtohex(l_system_guid));
764: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
765: l_source_type);
766: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
767: rawtohex(l_source_agent_guid));
768: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);

Line 766: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',

762: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
763: rawtohex(l_system_guid));
764: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
765: l_source_type);
766: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
767: rawtohex(l_source_agent_guid));
768: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
769:
770: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',

Line 768: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);

764: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
765: l_source_type);
766: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
767: rawtohex(l_source_agent_guid));
768: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
769:
770: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
771: l_phase);
772: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',

Line 770: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',

766: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
767: rawtohex(l_source_agent_guid));
768: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
769:
770: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
771: l_phase);
772: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
773: l_status);
774: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',

Line 772: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',

768: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
769:
770: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
771: l_phase);
772: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
773: l_status);
774: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
775: l_rule_data);
776: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',

Line 774: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',

770: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
771: l_phase);
772: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
773: l_status);
774: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
775: l_rule_data);
776: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
777: rawtohex(l_out_agent_guid));
778: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',

Line 776: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',

772: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
773: l_status);
774: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
775: l_rule_data);
776: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
777: rawtohex(l_out_agent_guid));
778: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
779: rawtohex(l_to_agent_guid));
780: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',

Line 778: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',

774: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
775: l_rule_data);
776: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
777: rawtohex(l_out_agent_guid));
778: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
779: rawtohex(l_to_agent_guid));
780: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',
781: l_PRIORITY);
782: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',

Line 780: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',

776: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
777: rawtohex(l_out_agent_guid));
778: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
779: rawtohex(l_to_agent_guid));
780: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',
781: l_PRIORITY);
782: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',
783: l_RULE_FUNCTION);
784: --Bug 3328673

Line 782: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',

778: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
779: rawtohex(l_to_agent_guid));
780: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',
781: l_PRIORITY);
782: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',
783: l_RULE_FUNCTION);
784: --Bug 3328673
785: --Add new tags for JBES support
786: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',

Line 786: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',

782: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',
783: l_RULE_FUNCTION);
784: --Bug 3328673
785: --Add new tags for JBES support
786: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',
787: l_javarulefunc);
788: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
789: l_standardtype);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',

Line 788: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',

784: --Bug 3328673
785: --Add new tags for JBES support
786: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',
787: l_javarulefunc);
788: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
789: l_standardtype);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
791: l_standardcode);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',

Line 790: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',

786: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',
787: l_javarulefunc);
788: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
789: l_standardtype);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
791: l_standardcode);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',
793: l_onerror);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',

Line 792: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',

788: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
789: l_standardtype);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
791: l_standardcode);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',
793: l_onerror);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',
795: l_actioncode);
796:

Line 794: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',

790: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
791: l_standardcode);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',
793: l_onerror);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',
795: l_actioncode);
796:
797: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
798: l_wf_process_type);

Line 797: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',

793: l_onerror);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',
795: l_actioncode);
796:
797: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
798: l_wf_process_type);
799: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
800: l_wf_process_name);
801: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',

Line 799: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',

795: l_actioncode);
796:
797: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
798: l_wf_process_type);
799: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
800: l_wf_process_name);
801: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
802: l_PARAMETERS);
803: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',

Line 801: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',

797: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
798: l_wf_process_type);
799: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
800: l_wf_process_name);
801: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
802: l_PARAMETERS);
803: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
804: l_OWNER_NAME);
805: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',

Line 803: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',

799: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
800: l_wf_process_name);
801: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
802: l_PARAMETERS);
803: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
804: l_OWNER_NAME);
805: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
806: l_OWNER_TAG);
807: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',

Line 805: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',

801: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
802: l_PARAMETERS);
803: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
804: l_OWNER_NAME);
805: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
806: l_OWNER_TAG);
807: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
808: NVL(l_customization_level, 'L'));
809: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',

Line 807: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',

803: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
804: l_OWNER_NAME);
805: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
806: l_OWNER_TAG);
807: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
808: NVL(l_customization_level, 'L'));
809: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
810: NVL(l_licensed_flag, 'Y'));
811: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',

Line 809: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',

805: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
806: l_OWNER_TAG);
807: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
808: NVL(l_customization_level, 'L'));
809: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
810: NVL(l_licensed_flag, 'Y'));
811: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',
812: l_DESCRIPTION);
813: l_node := wf_event_xml.newtag(l_doc, l_header, 'EXPRESSION',

Line 811: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',

807: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
808: NVL(l_customization_level, 'L'));
809: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
810: NVL(l_licensed_flag, 'Y'));
811: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',
812: l_DESCRIPTION);
813: l_node := wf_event_xml.newtag(l_doc, l_header, 'EXPRESSION',
814: l_EXPRESSION);
815: xmldom.writeToBuffer(l_root, buf);

Line 813: l_node := wf_event_xml.newtag(l_doc, l_header, 'EXPRESSION',

809: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
810: NVL(l_licensed_flag, 'Y'));
811: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',
812: l_DESCRIPTION);
813: l_node := wf_event_xml.newtag(l_doc, l_header, 'EXPRESSION',
814: l_EXPRESSION);
815: xmldom.writeToBuffer(l_root, buf);
816:
817: return buf;

Line 820: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Generate', x_guid);

816:
817: return buf;
818: exception
819: when others then
820: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Generate', x_guid);
821: raise;
822: end GENERATE;
823: -----------------------------------------------------------------------------
824: procedure RECEIVE (

Line 872: --l_message := WF_EVENT_SYNCHRONIZE_PKG.SetGUID(l_message); -- update #NEW

868: -- Identical Row checks from this procedure are now moved to Find_Subscription
869: begin
870:
871: l_message := x_message;
872: --l_message := WF_EVENT_SYNCHRONIZE_PKG.SetGUID(l_message); -- update #NEW
873: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
874: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
875: --Bug 3191978
876: --Replace agent names by their GUIDs

Line 873: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL

869: begin
870:
871: l_message := x_message;
872: --l_message := WF_EVENT_SYNCHRONIZE_PKG.SetGUID(l_message); -- update #NEW
873: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
874: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
875: --Bug 3191978
876: --Replace agent names by their GUIDs
877: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR

Line 874: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID

870:
871: l_message := x_message;
872: --l_message := WF_EVENT_SYNCHRONIZE_PKG.SetGUID(l_message); -- update #NEW
873: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
874: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
875: --Bug 3191978
876: --Replace agent names by their GUIDs
877: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
878: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);

Line 877: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR

873: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
874: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
875: --Bug 3191978
876: --Replace agent names by their GUIDs
877: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
878: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
879: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
880: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
881: l_length := xmldom.getLength(l_node_list);

Line 878: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);

874: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
875: --Bug 3191978
876: --Replace agent names by their GUIDs
877: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
878: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
879: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
880: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
881: l_length := xmldom.getLength(l_node_list);
882:

Line 879: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);

875: --Bug 3191978
876: --Replace agent names by their GUIDs
877: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
878: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
879: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
880: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
881: l_length := xmldom.getLength(l_node_list);
882:
883: -- loop through elements that we received.

Line 880: l_node_list := wf_event_xml.findTable(l_message, m_table_name);

876: --Replace agent names by their GUIDs
877: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
878: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
879: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
880: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
881: l_length := xmldom.getLength(l_node_list);
882:
883: -- loop through elements that we received.
884: for i in 0..l_length-1 loop

Line 908: FROM wf_events

904: -- Check if the value is event name, get the GUID
905: begin
906: SELECT guid
907: INTO l_event_filter_guid
908: FROM wf_events
909: WHERE name = l_value;
910: exception
911: when no_data_found then
912: -- Value is a event GUID (older wfx files)

Line 973: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then

969: -- Phase must not be null
970: if L_PHASE is null then
971: -- For backward compatibility of the WFXLoad do not raise any errors when
972: -- the caller is the Loader. Throw a warning only
973: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
974: Wf_Core.Token('REASON','Subscription Phase cannot be null');
975: Wf_Core.Raise('WFSQL_INTERNAL');
976: else
977: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',

Line 977: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',

973: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
974: Wf_Core.Token('REASON','Subscription Phase cannot be null');
975: Wf_Core.Raise('WFSQL_INTERNAL');
976: else
977: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
978: 'WARNING! WARNING! Subscription Phase CANNOT be null for Event GUID '
979: || l_event_filter_guid || ' defaulting to 50');
980: l_Phase := 50;
981: end if;

Line 991: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then

987: or (L_OWNER_TAG is null) then
988:
989: -- For backward compatibility of the WFXLoad do not raise any errors when
990: -- the caller is the Loader. Throw a warning only
991: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
992: Wf_Core.Token('REASON','Subscription Owner Name and Owner Tag cannot be null');
993: Wf_Core.Raise('WFSQL_INTERNAL');
994: else
995: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',

Line 995: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',

991: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
992: Wf_Core.Token('REASON','Subscription Owner Name and Owner Tag cannot be null');
993: Wf_Core.Raise('WFSQL_INTERNAL');
994: else
995: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
996: 'WARNING! WARNING! Subscription OWNER_NAME/OWNER_TAG CANNOT be null for Event GUID '
997: || l_event_filter_guid);
998: end if;
999: end if;

Line 1018: wf_event_subscriptions_pkg.load_row(

1014: x_parameters => l_parameters,
1015: x_owner_name => l_owner_name,
1016: x_owner_tag => l_owner_tag);
1017:
1018: wf_event_subscriptions_pkg.load_row(
1019: X_GUID => l_guid,
1020: X_SYSTEM_GUID => l_system_guid,
1021: X_SOURCE_TYPE => l_source_type,
1022: X_SOURCE_AGENT_GUID => l_source_agent_guid,

Line 1049: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive', x_message);

1045: );
1046:
1047: exception
1048: when others then
1049: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive', x_message);
1050: raise;
1051: end RECEIVE;
1052: -----------------------------------------------------------------------------
1053: procedure validate_subscription (X_EVENT_FILTER_GUID in raw,

Line 1060: from wf_events

1056: is
1057:
1058: cursor c_geteventcustom is
1059: select customization_level
1060: from wf_events
1061: where guid = X_EVENT_FILTER_GUID;
1062:
1063: l_custom_level varchar2(1);
1064: l_trns1 varchar2(4000);

Line 1103: WF_EVENT_SUBSCRIPTIONS

1099: X_CUSTOMIZATION_LEVEL out nocopy varchar2)
1100: is
1101: cursor c_getCustomLevel is
1102: select CUSTOMIZATION_LEVEL from
1103: WF_EVENT_SUBSCRIPTIONS
1104: where guid = X_GUID;
1105:
1106: l_found varchar2(1) := 'N';
1107: begin

Line 1146: FROM wf_event_subscriptions

1142: -- need to take care of cases where both values are null.
1143:
1144: CURSOR identical_row1 IS
1145: SELECT guid
1146: FROM wf_event_subscriptions
1147: WHERE system_guid = x_system_guid
1148: AND source_type = x_source_type
1149: AND event_filter_guid = x_event_filter_guid
1150: AND (((source_agent_guid is null) AND (x_source_agent_guid is null))

Line 1161: FROM wf_event_subscriptions

1157: OR owner_tag = x_owner_tag);
1158:
1159: CURSOR identical_row2 IS
1160: SELECT guid
1161: FROM wf_event_subscriptions
1162: WHERE system_guid = x_system_guid
1163: AND source_type = x_source_type
1164: AND event_filter_guid = x_event_filter_guid
1165: AND (phase is null OR phase = x_phase)

Line 1209: end WF_EVENT_SUBSCRIPTIONS_PKG;

1205: close identical_row1;
1206: return l_guid;
1207: end Find_Subscription;
1208:
1209: end WF_EVENT_SUBSCRIPTIONS_PKG;