102: exception
103: when no_data_found then
104: null;
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
103: when no_data_found then
104: null;
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
109: Wf_Core.Token('OWNERNAME', x_owner_name);
110: Wf_Core.Token('OWNERTAG', x_owner_tag);
111: Wf_Core.Raise('WFE_DUPLICATE_SUB');
104: null;
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
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
105: end;
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
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 (
106: Wf_Core.Token('EVENT', l_event_name);
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
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,
107: Wf_Core.Token('SOURCE', x_source_type);
108: Wf_Core.Token('PHASE', x_phase);
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,
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;
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);
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);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
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);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
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);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
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);
273: Wf_Core.Token('OWNERTAG', x_owner_tag);
274: Wf_Core.Raise('WFE_DUPLICATE_SUB');
275: end if;
276:
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);
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
270: Wf_Core.Token('SOURCE', x_source_type);
271: Wf_Core.Token('PHASE', x_phase);
272: Wf_Core.Token('OWNERNAME', x_owner_name);
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
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;
452: null;
453: end if;
454: else
455: -- Raise error..
456: Wf_Core.Token('REASON','Invalid Customization Level:' ||
457: l_custom_level);
458: Wf_Core.Raise('WFSQL_INTERNAL');
459: end if;
460:
454: else
455: -- Raise error..
456: Wf_Core.Token('REASON','Invalid Customization Level:' ||
457: l_custom_level);
458: Wf_Core.Raise('WFSQL_INTERNAL');
459: end if;
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
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: -----------------------------------------------------------------------------
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 (
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: ----------------------------------------------------------------------------
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 (
945: l_onerror := l_value;
946: elsif(l_node_name = 'ACTION_CODE') then
947: l_actioncode := l_value;
948: else
949: Wf_Core.Token('REASON', 'Invalid column name found:' ||
950: l_node_name || ' with value:'||l_value);
951: Wf_Core.Raise('WFSQL_INTERNAL');
952: end if;
953: end loop;
947: l_actioncode := l_value;
948: else
949: Wf_Core.Token('REASON', 'Invalid column name found:' ||
950: l_node_name || ' with value:'||l_value);
951: Wf_Core.Raise('WFSQL_INTERNAL');
952: end if;
953: end loop;
954:
955: -- Validate Subscription
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',
965: 'WARNING! WARNING! Subscription Phase CANNOT be null for Event GUID '
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',
965: 'WARNING! WARNING! Subscription Phase CANNOT be null for Event GUID '
966: || l_event_filter_guid || ' defaulting to 50');
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;
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',
983: 'WARNING! WARNING! Subscription OWNER_NAME/OWNER_TAG CANNOT be null for Event GUID '
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',
983: 'WARNING! WARNING! Subscription OWNER_NAME/OWNER_TAG CANNOT be null for Event GUID '
984: || l_event_filter_guid);
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;
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,
1074: end if;
1075: end if;
1076: exception
1077: when e_invalid_sub then
1078: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1079: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1080: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1081: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1082: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1075: end if;
1076: exception
1077: when e_invalid_sub then
1078: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1079: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1080: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1081: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1082: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1083: end validate_subscription;
1076: exception
1077: when e_invalid_sub then
1078: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1079: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1080: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1081: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1082: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1083: end validate_subscription;
1084:
1077: when e_invalid_sub then
1078: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1079: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1080: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1081: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1082: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1083: end validate_subscription;
1084:
1085: procedure fetch_custom_level(X_GUID in raw,
1078: l_trns1 := wf_core.translate('WFE_CUSTOM_LEVEL_' || X_CUSTOMIZATION_LEVEL);
1079: l_trns2 := wf_core.translate('WFE_CUSTOM_LEVEL_' || l_custom_level);
1080: wf_core.token('SUB_CUSTOM_LEVEL', l_trns1);
1081: wf_core.token('EVT_CUSTOM_LEVEL', l_trns2);
1082: wf_core.raise('WFE_INVALID_SUBSCRIPTION');
1083: end validate_subscription;
1084:
1085: procedure fetch_custom_level(X_GUID in raw,
1086: X_CUSTOMIZATION_LEVEL out nocopy varchar2)