DBA Data[Home] [Help]

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.6 2005/09/02 15:19:13 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.6 2005/09/02 15:19:13 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 366: if WF_EVENTS_PKG.g_Mode = 'UPGRADE' then

362: null;
363:
364: end if;
365: elsif X_CUSTOMIZATION_LEVEL = 'L' then
366: if WF_EVENTS_PKG.g_Mode = 'UPGRADE' then
367: -- Limit events can have only a status change..
368: -- When the loader is loading the events the
369: -- users changes must be preserved. Update all
370: -- fields EXCEPT the status field.

Line 371: update wf_event_subscriptions set

367: -- Limit events can have only a status change..
368: -- When the loader is loading the events the
369: -- users changes must be preserved. Update all
370: -- fields EXCEPT the status field.
371: update wf_event_subscriptions set
372: system_guid = X_SYSTEM_GUID,
373: source_type = X_SOURCE_TYPE,
374: source_agent_guid = X_SOURCE_AGENT_GUID,
375: event_filter_guid = X_EVENT_FILTER_GUID,

Line 405: update wf_event_subscriptions set

401: else -- Caller of the Update is UI
402: -- Limit events can have only a status change..
403: -- When the user is updating the event using the UI
404: -- Updates are allowed ONLY to the status field.
405: update wf_event_subscriptions set
406: status = X_STATUS,
407: licensed_flag = l_licensed_flag
408: where guid = X_GUID;
409:

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

414: elsif X_CUSTOMIZATION_LEVEL = 'U' then
415: -- Here are the updates allowed for extensible and User defined events
416: -- only when the caller is the UI
417:
418: if WF_EVENTS_PKG.g_Mode = 'CUSTOM' then
419: update wf_event_subscriptions set
420: system_guid = X_SYSTEM_GUID,
421: source_type = X_SOURCE_TYPE,
422: source_agent_guid = X_SOURCE_AGENT_GUID,

Line 419: update wf_event_subscriptions set

415: -- Here are the updates allowed for extensible and User defined events
416: -- only when the caller is the UI
417:
418: if WF_EVENTS_PKG.g_Mode = 'CUSTOM' then
419: update wf_event_subscriptions set
420: system_guid = X_SYSTEM_GUID,
421: source_type = X_SOURCE_TYPE,
422: source_agent_guid = X_SOURCE_AGENT_GUID,
423: event_filter_guid = X_EVENT_FILTER_GUID,

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

460:
461: -- Only raise if all if no raise_event_flag is set to 'Y'
462: -- fetch_custom_level will raise no_data_found if the subscription is not found
463: if (l_raise_event_flag = 'Y') then
464: wf_event.raise('oracle.apps.wf.event.subscription.update', X_GUID);
465: end if;
466:
467: end if;
468:

Line 503: WF_EVENT_SUBSCRIPTIONS_PKG.UPDATE_ROW (

499: ) is
500: row_id varchar2(64);
501: begin
502: begin
503: WF_EVENT_SUBSCRIPTIONS_PKG.UPDATE_ROW (
504: X_GUID => X_GUID,
505: X_SYSTEM_GUID => X_SYSTEM_GUID,
506: X_SOURCE_TYPE => X_SOURCE_TYPE,
507: X_SOURCE_AGENT_GUID => X_SOURCE_AGENT_GUID,

Line 534: WF_EVENT_SUBSCRIPTIONS_PKG.INSERT_ROW(

530: X_STANDARD_TYPE => X_STANDARD_TYPE
531: );
532: exception
533: when no_data_found then
534: WF_EVENT_SUBSCRIPTIONS_PKG.INSERT_ROW(
535: X_ROWID => row_id,
536: X_GUID => X_GUID,
537: X_SYSTEM_GUID => X_SYSTEM_GUID,
538: X_SOURCE_TYPE => X_SOURCE_TYPE,

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

566: -- Invalidate cache
567: wf_bes_cache.SetMetaDataUploaded();
568: exception
569: when others then
570: wf_core.context('Wf_Event_Subscriptions_Pkg', 'Load_Row', x_guid,
571: x_source_type, X_SOURCE_AGENT_GUID);
572: raise;
573: end LOAD_ROW;
574: -----------------------------------------------------------------------------

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

573: end LOAD_ROW;
574: -----------------------------------------------------------------------------
575: procedure DELETE_ROW (X_GUID in raw) is
576: begin
577: wf_event.raise('oracle.apps.wf.event.subscription.delete',x_guid);
578:
579: delete from wf_event_subscriptions
580: where guid = X_GUID;
581:

Line 579: delete from wf_event_subscriptions

575: procedure DELETE_ROW (X_GUID in raw) is
576: begin
577: wf_event.raise('oracle.apps.wf.event.subscription.delete',x_guid);
578:
579: delete from wf_event_subscriptions
580: where guid = X_GUID;
581:
582: if (sql%notfound) then
583: raise no_data_found;

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

586: -- Invalidate cache
587: wf_bes_cache.SetMetaDataUploaded();
588: exception
589: when others then
590: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Row', x_guid);
591: raise;
592: end DELETE_ROW;
593: ----------------------------------------------------------------------------
594: procedure DELETE_SET (

Line 621: delete from wf_event_subscriptions

617: X_STANDARD_CODE in varchar2,
618: X_STANDARD_TYPE in varchar2
619: ) is
620: begin
621: delete from wf_event_subscriptions
622: where (X_SYSTEM_GUID is null or (X_SYSTEM_GUID is not null
623: and system_guid like X_SYSTEM_GUID))
624: and (X_SOURCE_TYPE is null or (X_SOURCE_TYPE is not null
625: and source_type like X_SOURCE_TYPE))

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

671: -- Invalidate cache
672: wf_bes_cache.SetMetaDataUploaded();
673: exception
674: when others then
675: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Delete_Set',
676: x_system_guid, X_source_type, X_Event_Filter_GUID);
677: raise;
678: end DELETE_SET;
679: ----------------------------------------------------------------------------

Line 737: from wf_event_subscriptions s, wf_events e

733: l_rule_function, l_wf_process_type, l_wf_process_name,
734: l_parameters, l_owner_name, l_owner_tag, l_description, l_expression,
735: l_customization_level, l_licensed_flag,l_standardtype,l_standardcode,
736: l_javarulefunc,l_onerror , l_actioncode
737: from wf_event_subscriptions s, wf_events e
738: where s.guid = x_guid
739: and e.guid = s.event_filter_guid;
740:
741: l_doc := xmldom.newDOMDocument;

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

739: and e.guid = s.event_filter_guid;
740:
741: l_doc := xmldom.newDOMDocument;
742: l_root := xmldom.makeNode(l_doc);
743: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
744: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
745: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
746: m_package_version);
747: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',

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

740:
741: l_doc := xmldom.newDOMDocument;
742: l_root := xmldom.makeNode(l_doc);
743: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
744: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
745: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
746: m_package_version);
747: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
748: rawtohex(x_guid));

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

741: l_doc := xmldom.newDOMDocument;
742: l_root := xmldom.makeNode(l_doc);
743: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
744: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
745: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
746: m_package_version);
747: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
748: rawtohex(x_guid));
749: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',

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

743: l_root := wf_event_xml.newtag (l_doc, l_root, wf_event_xml.masterTagName);
744: l_header := wf_event_xml.newtag(l_doc, l_root, m_table_name);
745: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
746: m_package_version);
747: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
748: rawtohex(x_guid));
749: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
750: rawtohex(l_system_guid));
751: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',

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

745: l_node := wf_event_xml.newtag(l_doc, l_header, wf_event_xml.versionTagName,
746: m_package_version);
747: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
748: rawtohex(x_guid));
749: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
750: rawtohex(l_system_guid));
751: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
752: l_source_type);
753: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',

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

747: l_node := wf_event_xml.newtag(l_doc, l_header, 'GUID',
748: rawtohex(x_guid));
749: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
750: rawtohex(l_system_guid));
751: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
752: l_source_type);
753: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
754: rawtohex(l_source_agent_guid));
755: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);

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

749: l_node := wf_event_xml.newtag(l_doc, l_header, 'SYSTEM_GUID',
750: rawtohex(l_system_guid));
751: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
752: l_source_type);
753: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
754: rawtohex(l_source_agent_guid));
755: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
756:
757: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',

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

751: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_TYPE',
752: l_source_type);
753: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
754: rawtohex(l_source_agent_guid));
755: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
756:
757: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
758: l_phase);
759: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',

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

753: l_node := wf_event_xml.newtag(l_doc, l_header, 'SOURCE_AGENT_GUID',
754: rawtohex(l_source_agent_guid));
755: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
756:
757: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
758: l_phase);
759: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
760: l_status);
761: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',

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

755: l_node := wf_event_xml.newtag(l_doc, l_header, 'EVENT_FILTER_GUID', l_event_filter_name);
756:
757: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
758: l_phase);
759: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
760: l_status);
761: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
762: l_rule_data);
763: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',

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

757: l_node := wf_event_xml.newtag(l_doc, l_header, 'PHASE',
758: l_phase);
759: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
760: l_status);
761: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
762: l_rule_data);
763: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
764: rawtohex(l_out_agent_guid));
765: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',

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

759: l_node := wf_event_xml.newtag(l_doc, l_header, 'STATUS',
760: l_status);
761: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
762: l_rule_data);
763: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
764: rawtohex(l_out_agent_guid));
765: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
766: rawtohex(l_to_agent_guid));
767: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',

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

761: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_DATA',
762: l_rule_data);
763: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
764: rawtohex(l_out_agent_guid));
765: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
766: rawtohex(l_to_agent_guid));
767: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',
768: l_PRIORITY);
769: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',

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

763: l_node := wf_event_xml.newtag(l_doc, l_header, 'OUT_AGENT_GUID',
764: rawtohex(l_out_agent_guid));
765: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
766: rawtohex(l_to_agent_guid));
767: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',
768: l_PRIORITY);
769: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',
770: l_RULE_FUNCTION);
771: --Bug 3328673

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

765: l_node := wf_event_xml.newtag(l_doc, l_header, 'TO_AGENT_GUID',
766: rawtohex(l_to_agent_guid));
767: l_node := wf_event_xml.newtag(l_doc, l_header, 'PRIORITY',
768: l_PRIORITY);
769: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',
770: l_RULE_FUNCTION);
771: --Bug 3328673
772: --Add new tags for JBES support
773: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',

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

769: l_node := wf_event_xml.newtag(l_doc, l_header, 'RULE_FUNCTION',
770: l_RULE_FUNCTION);
771: --Bug 3328673
772: --Add new tags for JBES support
773: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',
774: l_javarulefunc);
775: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
776: l_standardtype);
777: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',

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

771: --Bug 3328673
772: --Add new tags for JBES support
773: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',
774: l_javarulefunc);
775: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
776: l_standardtype);
777: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
778: l_standardcode);
779: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',

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

773: l_node := wf_event_xml.newtag(l_doc, l_header, 'JAVA_RULE_FUNC',
774: l_javarulefunc);
775: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
776: l_standardtype);
777: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
778: l_standardcode);
779: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',
780: l_onerror);
781: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',

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

775: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_TYPE',
776: l_standardtype);
777: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
778: l_standardcode);
779: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',
780: l_onerror);
781: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',
782: l_actioncode);
783:

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

777: l_node := wf_event_xml.newtag(l_doc, l_header, 'STANDARD_CODE',
778: l_standardcode);
779: l_node := wf_event_xml.newtag(l_doc, l_header, 'ON_ERROR_CODE',
780: l_onerror);
781: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',
782: l_actioncode);
783:
784: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
785: l_wf_process_type);

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

780: l_onerror);
781: l_node := wf_event_xml.newtag(l_doc, l_header, 'ACTION_CODE',
782: l_actioncode);
783:
784: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
785: l_wf_process_type);
786: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
787: l_wf_process_name);
788: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',

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

782: l_actioncode);
783:
784: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
785: l_wf_process_type);
786: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
787: l_wf_process_name);
788: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
789: l_PARAMETERS);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',

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

784: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_TYPE',
785: l_wf_process_type);
786: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
787: l_wf_process_name);
788: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
789: l_PARAMETERS);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
791: l_OWNER_NAME);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',

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

786: l_node := wf_event_xml.newtag(l_doc, l_header, 'WF_PROCESS_NAME',
787: l_wf_process_name);
788: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
789: l_PARAMETERS);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
791: l_OWNER_NAME);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
793: l_OWNER_TAG);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',

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

788: l_node := wf_event_xml.newtag(l_doc, l_header, 'PARAMETERS',
789: l_PARAMETERS);
790: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
791: l_OWNER_NAME);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
793: l_OWNER_TAG);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
795: NVL(l_customization_level, 'L'));
796: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',

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

790: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_NAME',
791: l_OWNER_NAME);
792: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
793: l_OWNER_TAG);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
795: NVL(l_customization_level, 'L'));
796: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
797: NVL(l_licensed_flag, 'Y'));
798: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',

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

792: l_node := wf_event_xml.newtag(l_doc, l_header, 'OWNER_TAG',
793: l_OWNER_TAG);
794: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
795: NVL(l_customization_level, 'L'));
796: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
797: NVL(l_licensed_flag, 'Y'));
798: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',
799: l_DESCRIPTION);
800: l_node := wf_event_xml.newtag(l_doc, l_header, 'EXPRESSION',

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

794: l_node := wf_event_xml.newtag(l_doc, l_header, 'CUSTOMIZATION_LEVEL',
795: NVL(l_customization_level, 'L'));
796: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
797: NVL(l_licensed_flag, 'Y'));
798: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',
799: l_DESCRIPTION);
800: l_node := wf_event_xml.newtag(l_doc, l_header, 'EXPRESSION',
801: l_EXPRESSION);
802: xmldom.writeToBuffer(l_root, buf);

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

796: l_node := wf_event_xml.newtag(l_doc, l_header, 'LICENSED_FLAG',
797: NVL(l_licensed_flag, 'Y'));
798: l_node := wf_event_xml.newtag(l_doc, l_header, 'DESCRIPTION',
799: l_DESCRIPTION);
800: l_node := wf_event_xml.newtag(l_doc, l_header, 'EXPRESSION',
801: l_EXPRESSION);
802: xmldom.writeToBuffer(l_root, buf);
803:
804: return buf;

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

803:
804: return buf;
805: exception
806: when others then
807: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Generate', x_guid);
808: raise;
809: end GENERATE;
810: -----------------------------------------------------------------------------
811: procedure RECEIVE (

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

855: -- Identical Row checks from this procedure are now moved to Find_Subscription
856: begin
857:
858: l_message := x_message;
859: --l_message := WF_EVENT_SYNCHRONIZE_PKG.SetGUID(l_message); -- update #NEW
860: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
861: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
862: --Bug 3191978
863: --Replace agent names by their GUIDs

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

856: begin
857:
858: l_message := x_message;
859: --l_message := WF_EVENT_SYNCHRONIZE_PKG.SetGUID(l_message); -- update #NEW
860: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
861: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
862: --Bug 3191978
863: --Replace agent names by their GUIDs
864: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR

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

857:
858: l_message := x_message;
859: --l_message := WF_EVENT_SYNCHRONIZE_PKG.SetGUID(l_message); -- update #NEW
860: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
861: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
862: --Bug 3191978
863: --Replace agent names by their GUIDs
864: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
865: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);

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

860: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSYSTEMGUID(l_message); -- update #LOCAL
861: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
862: --Bug 3191978
863: --Replace agent names by their GUIDs
864: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
865: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
866: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
867: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
868: l_length := xmldom.getLength(l_node_list);

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

861: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetSID(l_message); -- update #SID
862: --Bug 3191978
863: --Replace agent names by their GUIDs
864: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
865: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
866: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
867: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
868: l_length := xmldom.getLength(l_node_list);
869:

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

862: --Bug 3191978
863: --Replace agent names by their GUIDs
864: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
865: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
866: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
867: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
868: l_length := xmldom.getLength(l_node_list);
869:
870: -- loop through elements that we received.

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

863: --Replace agent names by their GUIDs
864: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message); -- update #WF_IN, #WF_OUT, #WF_ERROR
865: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
866: l_message := WF_EVENT_SYNCHRONIZE_PKG.SetAgent2('','',l_message);
867: l_node_list := wf_event_xml.findTable(l_message, m_table_name);
868: l_length := xmldom.getLength(l_node_list);
869:
870: -- loop through elements that we received.
871: for i in 0..l_length-1 loop

Line 895: FROM wf_events

891: -- Check if the value is event name, get the GUID
892: begin
893: SELECT guid
894: INTO l_event_filter_guid
895: FROM wf_events
896: WHERE name = l_value;
897: exception
898: when no_data_found then
899: -- Value is a event GUID (older wfx files)

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

956: -- Phase must not be null
957: if L_PHASE is null then
958: -- For backward compatibility of the WFXLoad do not raise any errors when
959: -- the caller is the Loader. Throw a warning only
960: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
961: Wf_Core.Token('REASON','Subscription Phase cannot be null');
962: Wf_Core.Raise('WFSQL_INTERNAL');
963: else
964: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',

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

960: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
961: Wf_Core.Token('REASON','Subscription Phase cannot be null');
962: Wf_Core.Raise('WFSQL_INTERNAL');
963: else
964: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
965: 'WARNING! WARNING! Subscription Phase CANNOT be null for Event GUID '
966: || l_event_filter_guid || ' defaulting to 50');
967: l_Phase := 50;
968: end if;

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

974: or (L_OWNER_TAG is null) then
975:
976: -- For backward compatibility of the WFXLoad do not raise any errors when
977: -- the caller is the Loader. Throw a warning only
978: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
979: Wf_Core.Token('REASON','Subscription Owner Name and Owner Tag cannot be null');
980: Wf_Core.Raise('WFSQL_INTERNAL');
981: else
982: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',

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

978: if WF_EVENTS_PKG.g_Mode <> 'UPGRADE' then
979: Wf_Core.Token('REASON','Subscription Owner Name and Owner Tag cannot be null');
980: Wf_Core.Raise('WFSQL_INTERNAL');
981: else
982: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive',
983: 'WARNING! WARNING! Subscription OWNER_NAME/OWNER_TAG CANNOT be null for Event GUID '
984: || l_event_filter_guid);
985: end if;
986: end if;

Line 1005: wf_event_subscriptions_pkg.load_row(

1001: x_parameters => l_parameters,
1002: x_owner_name => l_owner_name,
1003: x_owner_tag => l_owner_tag);
1004:
1005: wf_event_subscriptions_pkg.load_row(
1006: X_GUID => l_guid,
1007: X_SYSTEM_GUID => l_system_guid,
1008: X_SOURCE_TYPE => l_source_type,
1009: X_SOURCE_AGENT_GUID => l_source_agent_guid,

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

1032: );
1033:
1034: exception
1035: when others then
1036: wf_core.context('Wf_Events_Subscriptions_Pkg', 'Receive', x_message);
1037: raise;
1038: end RECEIVE;
1039: -----------------------------------------------------------------------------
1040: procedure validate_subscription (X_EVENT_FILTER_GUID in raw,

Line 1047: from wf_events

1043: is
1044:
1045: cursor c_geteventcustom is
1046: select customization_level
1047: from wf_events
1048: where guid = X_EVENT_FILTER_GUID;
1049:
1050: l_custom_level varchar2(1);
1051: l_trns1 varchar2(4000);

Line 1090: WF_EVENT_SUBSCRIPTIONS

1086: X_CUSTOMIZATION_LEVEL out nocopy varchar2)
1087: is
1088: cursor c_getCustomLevel is
1089: select CUSTOMIZATION_LEVEL from
1090: WF_EVENT_SUBSCRIPTIONS
1091: where guid = X_GUID;
1092:
1093: l_found varchar2(1) := 'N';
1094: begin

Line 1133: FROM wf_event_subscriptions

1129: -- need to take care of cases where both values are null.
1130:
1131: CURSOR identical_row1 IS
1132: SELECT guid
1133: FROM wf_event_subscriptions
1134: WHERE system_guid = x_system_guid
1135: AND source_type = x_source_type
1136: AND event_filter_guid = x_event_filter_guid
1137: AND (((source_agent_guid is null) AND (x_source_agent_guid is null))

Line 1148: FROM wf_event_subscriptions

1144: OR owner_tag = x_owner_tag);
1145:
1146: CURSOR identical_row2 IS
1147: SELECT guid
1148: FROM wf_event_subscriptions
1149: WHERE system_guid = x_system_guid
1150: AND source_type = x_source_type
1151: AND event_filter_guid = x_event_filter_guid
1152: AND (phase is null OR phase = x_phase)

Line 1196: end WF_EVENT_SUBSCRIPTIONS_PKG;

1192: close identical_row1;
1193: return l_guid;
1194: end Find_Subscription;
1195:
1196: end WF_EVENT_SUBSCRIPTIONS_PKG;