DBA Data[Home] [Help]

APPS.WF_EVENT dependencies on WF_CORE

Line 96: wf_core.context('Wf_Event', 'setMessage', ename, ekey);

92:
93: l_event_obj := wf_bes_cache.GetEventByName(ename);
94:
95: if (l_event_obj is null) then
96: wf_core.context('Wf_Event', 'setMessage', ename, ekey);
97: wf_core.raise('WFE_EVENT_NOTEXIST');
98: end if;
99:
100: func := l_event_obj.GENERATE_FUNCTION;

Line 97: wf_core.raise('WFE_EVENT_NOTEXIST');

93: l_event_obj := wf_bes_cache.GetEventByName(ename);
94:
95: if (l_event_obj is null) then
96: wf_core.context('Wf_Event', 'setMessage', ename, ekey);
97: wf_core.raise('WFE_EVENT_NOTEXIST');
98: end if;
99:
100: func := l_event_obj.GENERATE_FUNCTION;
101:

Line 153: if (Wf_Core.Error_Name = 'WFE_EVENT_NOTEXIST') then

149: -- p_event.setEventData(msg);
150: --end if;
151: exception
152: when others then
153: if (Wf_Core.Error_Name = 'WFE_EVENT_NOTEXIST') then
154: raise;
155: else
156: wf_core.context('Wf_Event', 'setMessage', ename, ekey, func);
157: WF_CORE.Token('ENAME', p_event.event_name);

Line 156: wf_core.context('Wf_Event', 'setMessage', ename, ekey, func);

152: when others then
153: if (Wf_Core.Error_Name = 'WFE_EVENT_NOTEXIST') then
154: raise;
155: else
156: wf_core.context('Wf_Event', 'setMessage', ename, ekey, func);
157: WF_CORE.Token('ENAME', p_event.event_name);
158: wf_core.token('FUNCTION_NAME', func);
159: WF_CORE.Token('SQLCODE', to_char(sqlcode));
160: WF_CORE.Token('SQLERRM', sqlerrm);

Line 157: WF_CORE.Token('ENAME', p_event.event_name);

153: if (Wf_Core.Error_Name = 'WFE_EVENT_NOTEXIST') then
154: raise;
155: else
156: wf_core.context('Wf_Event', 'setMessage', ename, ekey, func);
157: WF_CORE.Token('ENAME', p_event.event_name);
158: wf_core.token('FUNCTION_NAME', func);
159: WF_CORE.Token('SQLCODE', to_char(sqlcode));
160: WF_CORE.Token('SQLERRM', sqlerrm);
161: WF_CORE.Raise('WFE_DISPATCH_GEN_ERR');

Line 158: wf_core.token('FUNCTION_NAME', func);

154: raise;
155: else
156: wf_core.context('Wf_Event', 'setMessage', ename, ekey, func);
157: WF_CORE.Token('ENAME', p_event.event_name);
158: wf_core.token('FUNCTION_NAME', func);
159: WF_CORE.Token('SQLCODE', to_char(sqlcode));
160: WF_CORE.Token('SQLERRM', sqlerrm);
161: WF_CORE.Raise('WFE_DISPATCH_GEN_ERR');
162: end if;

Line 159: WF_CORE.Token('SQLCODE', to_char(sqlcode));

155: else
156: wf_core.context('Wf_Event', 'setMessage', ename, ekey, func);
157: WF_CORE.Token('ENAME', p_event.event_name);
158: wf_core.token('FUNCTION_NAME', func);
159: WF_CORE.Token('SQLCODE', to_char(sqlcode));
160: WF_CORE.Token('SQLERRM', sqlerrm);
161: WF_CORE.Raise('WFE_DISPATCH_GEN_ERR');
162: end if;
163: end;

Line 160: WF_CORE.Token('SQLERRM', sqlerrm);

156: wf_core.context('Wf_Event', 'setMessage', ename, ekey, func);
157: WF_CORE.Token('ENAME', p_event.event_name);
158: wf_core.token('FUNCTION_NAME', func);
159: WF_CORE.Token('SQLCODE', to_char(sqlcode));
160: WF_CORE.Token('SQLERRM', sqlerrm);
161: WF_CORE.Raise('WFE_DISPATCH_GEN_ERR');
162: end if;
163: end;
164: -----------------------------------------------------------------------

Line 161: WF_CORE.Raise('WFE_DISPATCH_GEN_ERR');

157: WF_CORE.Token('ENAME', p_event.event_name);
158: wf_core.token('FUNCTION_NAME', func);
159: WF_CORE.Token('SQLCODE', to_char(sqlcode));
160: WF_CORE.Token('SQLERRM', sqlerrm);
161: WF_CORE.Raise('WFE_DISPATCH_GEN_ERR');
162: end if;
163: end;
164: -----------------------------------------------------------------------
165: /*

Line 182: -- First look for a standard WF_CORE exception.

178: 'wf.plsql.WF_EVENT.setErrorInfo.begin',
179: 'Setting Error Info');
180: end if;
181:
182: -- First look for a standard WF_CORE exception.
183: wf_core.get_error(err_name, err_msg, err_stack, 2000);
184:
185: if (err_name is null) then
186: -- If no WF_CORE exception, look for an Oracle error.

Line 183: wf_core.get_error(err_name, err_msg, err_stack, 2000);

179: 'Setting Error Info');
180: end if;
181:
182: -- First look for a standard WF_CORE exception.
183: wf_core.get_error(err_name, err_msg, err_stack, 2000);
184:
185: if (err_name is null) then
186: -- If no WF_CORE exception, look for an Oracle error.
187: err_name := to_char(sqlcode);

Line 186: -- If no WF_CORE exception, look for an Oracle error.

182: -- First look for a standard WF_CORE exception.
183: wf_core.get_error(err_name, err_msg, err_stack, 2000);
184:
185: if (err_name is null) then
186: -- If no WF_CORE exception, look for an Oracle error.
187: err_name := to_char(sqlcode);
188: err_msg := sqlerrm;
189: end if;
190:

Line 198: wf_core.context('Wf_Event', 'setErrorInfo', p_event.getEventName());

194: p_event.addParameterToList('ERROR_NAME', err_name);
195: p_event.addParameterToList('ERROR_TYPE', p_type);
196: exception
197: when others then
198: wf_core.context('Wf_Event', 'setErrorInfo', p_event.getEventName());
199: raise;
200: end;
201: -----------------------------------------------------------------------
202: /*

Line 234: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());

230: 'error info saved');
231: end if;
232: exception
233: when others then
234: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());
235: wf_core.token('FUNCTION_NAME', 'WF_ERROR_QH.enqueue()');
236: --wf_core.raise('WF_EXT_FUNCTION');
237: raise;
238: end;

Line 235: wf_core.token('FUNCTION_NAME', 'WF_ERROR_QH.enqueue()');

231: end if;
232: exception
233: when others then
234: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());
235: wf_core.token('FUNCTION_NAME', 'WF_ERROR_QH.enqueue()');
236: --wf_core.raise('WF_EXT_FUNCTION');
237: raise;
238: end;
239: --------------------------------------------------------------------------

Line 236: --wf_core.raise('WF_EXT_FUNCTION');

232: exception
233: when others then
234: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());
235: wf_core.token('FUNCTION_NAME', 'WF_ERROR_QH.enqueue()');
236: --wf_core.raise('WF_EXT_FUNCTION');
237: raise;
238: end;
239: --------------------------------------------------------------------------
240: -----------------------------------------------------------------------

Line 273: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());

269: 'error info saved');
270: end if;
271: exception
272: when others then
273: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());
274: wf_core.token('FUNCTION_NAME', 'WF_EVENT_OJMSTEXT_QH.enqueue()');
275: --wf_core.raise('WF_EXT_FUNCTION');
276: raise;
277: end;

Line 274: wf_core.token('FUNCTION_NAME', 'WF_EVENT_OJMSTEXT_QH.enqueue()');

270: end if;
271: exception
272: when others then
273: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());
274: wf_core.token('FUNCTION_NAME', 'WF_EVENT_OJMSTEXT_QH.enqueue()');
275: --wf_core.raise('WF_EXT_FUNCTION');
276: raise;
277: end;
278: --------------------------------------------------------------------------

Line 275: --wf_core.raise('WF_EXT_FUNCTION');

271: exception
272: when others then
273: wf_core.context('Wf_Event', 'saveErrorToQueue', p_event.getEventName());
274: wf_core.token('FUNCTION_NAME', 'WF_EVENT_OJMSTEXT_QH.enqueue()');
275: --wf_core.raise('WF_EXT_FUNCTION');
276: raise;
277: end;
278: --------------------------------------------------------------------------
279: /*

Line 401: wf_core.context('Wf_Event', 'isDeferToJava', p_event_name);

397:
398: return false;
399: exception
400: when others then
401: wf_core.context('Wf_Event', 'isDeferToJava', p_event_name);
402: raise;
403: end isDeferToJava;
404:
405: --------------------------------------------------------------------------

Line 489: if (wf_core.database_current_edition <> wf_core.database_default_edition) and

485: executed boolean;
486: begin
487: -- Bug 11850350. If database is in PATCH EDITION then
488: -- do not process the event at all. Just return
489: if (wf_core.database_current_edition <> wf_core.database_default_edition) and
490: (p_event.send_date is null or p_event.send_date <= sysdate) then
491: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
492: wf_log_pkg.string(wf_log_pkg.level_statement,
493: 'wf.plsql.WF_EVENT.dispatch_internal',

Line 734: WF_CORE.Token('ENAME', p_event.event_name);

730: rollback to wf_dispatch_savepoint;
731: p_event.setErrorSubscription(p_sub_guid);
732: p_event.addParameterToList('ERROR_TYPE', 'UNEXPECTED');
733: wf_event.wf_exception_source := 'RULE';
734: WF_CORE.Token('ENAME', p_event.event_name);
735: WF_CORE.Token('EKEY', p_event.event_key);
736: WF_CORE.Token('RULE', myfunc);
737: WF_CORE.Token('SQLCODE', to_char(sqlcode));
738: WF_CORE.Token('SQLERRM', sqlerrm);

Line 735: WF_CORE.Token('EKEY', p_event.event_key);

731: p_event.setErrorSubscription(p_sub_guid);
732: p_event.addParameterToList('ERROR_TYPE', 'UNEXPECTED');
733: wf_event.wf_exception_source := 'RULE';
734: WF_CORE.Token('ENAME', p_event.event_name);
735: WF_CORE.Token('EKEY', p_event.event_key);
736: WF_CORE.Token('RULE', myfunc);
737: WF_CORE.Token('SQLCODE', to_char(sqlcode));
738: WF_CORE.Token('SQLERRM', sqlerrm);
739: WF_CORE.Raise('WFE_DISPATCH_RULE_ERR');

Line 736: WF_CORE.Token('RULE', myfunc);

732: p_event.addParameterToList('ERROR_TYPE', 'UNEXPECTED');
733: wf_event.wf_exception_source := 'RULE';
734: WF_CORE.Token('ENAME', p_event.event_name);
735: WF_CORE.Token('EKEY', p_event.event_key);
736: WF_CORE.Token('RULE', myfunc);
737: WF_CORE.Token('SQLCODE', to_char(sqlcode));
738: WF_CORE.Token('SQLERRM', sqlerrm);
739: WF_CORE.Raise('WFE_DISPATCH_RULE_ERR');
740: end if;

Line 737: WF_CORE.Token('SQLCODE', to_char(sqlcode));

733: wf_event.wf_exception_source := 'RULE';
734: WF_CORE.Token('ENAME', p_event.event_name);
735: WF_CORE.Token('EKEY', p_event.event_key);
736: WF_CORE.Token('RULE', myfunc);
737: WF_CORE.Token('SQLCODE', to_char(sqlcode));
738: WF_CORE.Token('SQLERRM', sqlerrm);
739: WF_CORE.Raise('WFE_DISPATCH_RULE_ERR');
740: end if;
741:

Line 738: WF_CORE.Token('SQLERRM', sqlerrm);

734: WF_CORE.Token('ENAME', p_event.event_name);
735: WF_CORE.Token('EKEY', p_event.event_key);
736: WF_CORE.Token('RULE', myfunc);
737: WF_CORE.Token('SQLCODE', to_char(sqlcode));
738: WF_CORE.Token('SQLERRM', sqlerrm);
739: WF_CORE.Raise('WFE_DISPATCH_RULE_ERR');
740: end if;
741:
742: end;

Line 739: WF_CORE.Raise('WFE_DISPATCH_RULE_ERR');

735: WF_CORE.Token('EKEY', p_event.event_key);
736: WF_CORE.Token('RULE', myfunc);
737: WF_CORE.Token('SQLCODE', to_char(sqlcode));
738: WF_CORE.Token('SQLERRM', sqlerrm);
739: WF_CORE.Raise('WFE_DISPATCH_RULE_ERR');
740: end if;
741:
742: end;
743:

Line 776: wf_core.token('ENAME', p_event.event_name);

772: -- If subscription returns error when listener listens on error agent.
773: -- Bug 4207885: Set the exception source to Rule when
774: -- Raising exceptions.
775: wf_event.wf_exception_source := 'RULE';
776: wf_core.token('ENAME', p_event.event_name);
777: wf_core.token('EKEY', p_event.event_key);
778: wf_core.token('SQLERRM', null);
779: wf_core.token('SQLCODE', null);
780: wf_core.raise('WFE_DISPATCH_RULE_ERR');

Line 777: wf_core.token('EKEY', p_event.event_key);

773: -- Bug 4207885: Set the exception source to Rule when
774: -- Raising exceptions.
775: wf_event.wf_exception_source := 'RULE';
776: wf_core.token('ENAME', p_event.event_name);
777: wf_core.token('EKEY', p_event.event_key);
778: wf_core.token('SQLERRM', null);
779: wf_core.token('SQLCODE', null);
780: wf_core.raise('WFE_DISPATCH_RULE_ERR');
781: end if;

Line 778: wf_core.token('SQLERRM', null);

774: -- Raising exceptions.
775: wf_event.wf_exception_source := 'RULE';
776: wf_core.token('ENAME', p_event.event_name);
777: wf_core.token('EKEY', p_event.event_key);
778: wf_core.token('SQLERRM', null);
779: wf_core.token('SQLCODE', null);
780: wf_core.raise('WFE_DISPATCH_RULE_ERR');
781: end if;
782:

Line 779: wf_core.token('SQLCODE', null);

775: wf_event.wf_exception_source := 'RULE';
776: wf_core.token('ENAME', p_event.event_name);
777: wf_core.token('EKEY', p_event.event_key);
778: wf_core.token('SQLERRM', null);
779: wf_core.token('SQLCODE', null);
780: wf_core.raise('WFE_DISPATCH_RULE_ERR');
781: end if;
782:
783: if (res = 'ERROR') then

Line 780: wf_core.raise('WFE_DISPATCH_RULE_ERR');

776: wf_core.token('ENAME', p_event.event_name);
777: wf_core.token('EKEY', p_event.event_key);
778: wf_core.token('SQLERRM', null);
779: wf_core.token('SQLCODE', null);
780: wf_core.raise('WFE_DISPATCH_RULE_ERR');
781: end if;
782:
783: if (res = 'ERROR') then
784:

Line 803: wf_core.token('EVENT',p_event.getEventName());

799: -- Bug 1840819
800: -- Catch the no savepoint exception incase commit has happened.
801: -- In this case, the subsequent subscriptions can't be executed
802: -- because is savepoint no longer valid.
803: wf_core.token('EVENT',p_event.getEventName());
804: p_event.setErrorMessage(wf_core.substitute('WFERR',
805: 'WFE_COMMIT_IN_DISPATCH'));
806: res := 'TRANSACTION_COMMITED';
807: end;

Line 804: p_event.setErrorMessage(wf_core.substitute('WFERR',

800: -- Catch the no savepoint exception incase commit has happened.
801: -- In this case, the subsequent subscriptions can't be executed
802: -- because is savepoint no longer valid.
803: wf_core.token('EVENT',p_event.getEventName());
804: p_event.setErrorMessage(wf_core.substitute('WFERR',
805: 'WFE_COMMIT_IN_DISPATCH'));
806: res := 'TRANSACTION_COMMITED';
807: end;
808: end if;

Line 817: wf_core.context('Wf_Event', 'dispatch_internal');

813: return (res);
814:
815: exception
816: when others then
817: wf_core.context('Wf_Event', 'dispatch_internal');
818: raise;
819: end;
820: ---------------------------------------------------------------------------
821: /*

Line 841: wf_core.raise('WFE_AGENT_NOTEXIST');

837:
838: if (l_agent_obj is not null) then
839: return wf_agent_t(l_agent_obj.NAME, l_agent_obj.SYSTEM_NAME);
840: else
841: wf_core.raise('WFE_AGENT_NOTEXIST');
842: end if;
843: exception
844: when others then
845: wf_core.context('Wf_Event', 'newAgent', p_agent_guid);

Line 845: wf_core.context('Wf_Event', 'newAgent', p_agent_guid);

841: wf_core.raise('WFE_AGENT_NOTEXIST');
842: end if;
843: exception
844: when others then
845: wf_core.context('Wf_Event', 'newAgent', p_agent_guid);
846: raise;
847: end;
848: ---------------------------------------------------------------------------
849: /*

Line 884: wf_core.context('Wf_Event', 'Test', p_event_name);

880: return result;
881:
882: exception
883: when others then
884: wf_core.context('Wf_Event', 'Test', p_event_name);
885: raise;
886: end;
887: ---------------------------------------------------------------------------
888: /*

Line 915: wf_core.context('Wf_Event', 'Send', p_event.getEventName());

911: --
912: if (p_event.GetToAgent() is null AND p_event.GetFromAgent() is null) then
913: -- Either source or destination must be defined.
914: -- Raise Error.
915: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
916: wf_core.raise('Either source or destination must be defined.'); -- wfsql.msg
917: end if;
918:
919: if p_event.GetToAgent() is not null then

Line 916: wf_core.raise('Either source or destination must be defined.'); -- wfsql.msg

912: if (p_event.GetToAgent() is null AND p_event.GetFromAgent() is null) then
913: -- Either source or destination must be defined.
914: -- Raise Error.
915: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
916: wf_core.raise('Either source or destination must be defined.'); -- wfsql.msg
917: end if;
918:
919: if p_event.GetToAgent() is not null then
920: toagtname := p_event.getToAgent().getName();

Line 989: wf_core.context('Wf_Event', 'Send', p_event.getEventName());

985:
986: wf_event.enqueue(p_event);
987: exception
988: when no_data_found then
989: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
990: wf_core.token('AGENT', toagtname);
991: wf_core.raise('WFE_AGENT_NOMATCH');
992: when others then
993: wf_core.context('Wf_Event', 'Send', p_event.getEventName());

Line 990: wf_core.token('AGENT', toagtname);

986: wf_event.enqueue(p_event);
987: exception
988: when no_data_found then
989: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
990: wf_core.token('AGENT', toagtname);
991: wf_core.raise('WFE_AGENT_NOMATCH');
992: when others then
993: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
994: raise;

Line 991: wf_core.raise('WFE_AGENT_NOMATCH');

987: exception
988: when no_data_found then
989: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
990: wf_core.token('AGENT', toagtname);
991: wf_core.raise('WFE_AGENT_NOMATCH');
992: when others then
993: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
994: raise;
995: end;

Line 993: wf_core.context('Wf_Event', 'Send', p_event.getEventName());

989: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
990: wf_core.token('AGENT', toagtname);
991: wf_core.raise('WFE_AGENT_NOMATCH');
992: when others then
993: wf_core.context('Wf_Event', 'Send', p_event.getEventName());
994: raise;
995: end;
996: ---------------------------------------------------------------------------
997: /*

Line 1065: wf_core.context('WF_EVENT', 'Get_Recipient', 'Bad Protocol',

1061: -- from protocol names as used in the event manager and the
1062: -- protocol numbers used by AQ.
1063:
1064: if((l_to_protocol is null) or (l_to_protocol not in ('SQLNET'))) then
1065: wf_core.context('WF_EVENT', 'Get_Recipient', 'Bad Protocol',
1066: l_to_protocol, l_to_queue_name);
1067: end if;
1068:
1069: return sys.aq$_agent(p_to_agent_name,

Line 1270: WF_CORE.Context('WF_EVENT', 'Listen', p_agent_name, p_correlation,

1266: p_max_error_count := 0;
1267: end if;
1268:
1269: if ((p_correlation is not NULL) and (p_deq_condition is not NULL)) then
1270: WF_CORE.Context('WF_EVENT', 'Listen', p_agent_name, p_correlation,
1271: p_deq_condition);
1272: WF_CORE.Raise('WFE_CORRID_VS_CONDITION');
1273:
1274: end if;

Line 1272: WF_CORE.Raise('WFE_CORRID_VS_CONDITION');

1268:
1269: if ((p_correlation is not NULL) and (p_deq_condition is not NULL)) then
1270: WF_CORE.Context('WF_EVENT', 'Listen', p_agent_name, p_correlation,
1271: p_deq_condition);
1272: WF_CORE.Raise('WFE_CORRID_VS_CONDITION');
1273:
1274: end if;
1275:
1276: -- lookup agent info --

Line 1280: g_local_system_guid := hextoraw(WF_CORE.Translate('WF_SYSTEM_GUID'));

1276: -- lookup agent info --
1277: -- Tuned and separated sql statement for better performance
1278: -- restricting Listen() to local system.
1279: if (WF_EVENT.g_local_system_guid is NULL) then
1280: g_local_system_guid := hextoraw(WF_CORE.Translate('WF_SYSTEM_GUID'));
1281: end if;
1282:
1283: -- get the agent information for the local system
1284: l_agent_obj := wf_bes_cache.GetAgentByName(p_agent_name, null);

Line 1313: wf_core.context('Wf_Event', 'Listen', p_agent_name);

1309: else
1310: --This is a transactional queue, but since there was a correlation id
1311: --passed, we cannot call Listen_GRP, so we will raise an error to the
1312: --caller to resolve.
1313: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1314: wf_core.token('AGENT', p_agent_name);
1315: wf_core.token('API', 'WF_EVENT.Listen_GRP');
1316: wf_core.raise('WFE_TRXN_QUEUE');
1317:

Line 1314: wf_core.token('AGENT', p_agent_name);

1310: --This is a transactional queue, but since there was a correlation id
1311: --passed, we cannot call Listen_GRP, so we will raise an error to the
1312: --caller to resolve.
1313: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1314: wf_core.token('AGENT', p_agent_name);
1315: wf_core.token('API', 'WF_EVENT.Listen_GRP');
1316: wf_core.raise('WFE_TRXN_QUEUE');
1317:
1318: end if;

Line 1315: wf_core.token('API', 'WF_EVENT.Listen_GRP');

1311: --passed, we cannot call Listen_GRP, so we will raise an error to the
1312: --caller to resolve.
1313: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1314: wf_core.token('AGENT', p_agent_name);
1315: wf_core.token('API', 'WF_EVENT.Listen_GRP');
1316: wf_core.raise('WFE_TRXN_QUEUE');
1317:
1318: end if;
1319: end if;

Line 1316: wf_core.raise('WFE_TRXN_QUEUE');

1312: --caller to resolve.
1313: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1314: wf_core.token('AGENT', p_agent_name);
1315: wf_core.token('API', 'WF_EVENT.Listen_GRP');
1316: wf_core.raise('WFE_TRXN_QUEUE');
1317:
1318: end if;
1319: end if;
1320:

Line 1329: -- stat := wf_core.translate('WF_SYSTEM_STATUS');

1325: st := 'EXTERNAL';
1326: end if;
1327:
1328: -- check system status
1329: -- stat := wf_core.translate('WF_SYSTEM_STATUS');
1330: -- Set the account name - only need this for WF_DEFERRED
1331: wf_event.SetAccountName;
1332:
1333: if (wf_event.local_system_status = 'DISABLED' OR

Line 1334: wf_core.database_current_edition <> wf_core.database_default_edition) then

1330: -- Set the account name - only need this for WF_DEFERRED
1331: wf_event.SetAccountName;
1332:
1333: if (wf_event.local_system_status = 'DISABLED' OR
1334: wf_core.database_current_edition <> wf_core.database_default_edition) then
1335: return;
1336: end if;
1337:
1338: if (wf_event.local_system_status in ('LOCAL','EXTERNAL')) then

Line 1412: evt_errmsg := evt.getErrorMessage || wf_core.newline ||

1408:
1409: IF evt_name IS NULL THEN
1410: evt.setEventName('UNEXPECTED_ERROR');
1411: evt.setEventKey('UNEXPERR');
1412: evt_errmsg := evt.getErrorMessage || wf_core.newline ||
1413: wf_core.translate('WF_EVTNAME_NULL');
1414: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));
1415: END IF;
1416: end if;

Line 1413: wf_core.translate('WF_EVTNAME_NULL');

1409: IF evt_name IS NULL THEN
1410: evt.setEventName('UNEXPECTED_ERROR');
1411: evt.setEventKey('UNEXPERR');
1412: evt_errmsg := evt.getErrorMessage || wf_core.newline ||
1413: wf_core.translate('WF_EVTNAME_NULL');
1414: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));
1415: END IF;
1416: end if;
1417:

Line 1414: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));

1410: evt.setEventName('UNEXPECTED_ERROR');
1411: evt.setEventKey('UNEXPERR');
1412: evt_errmsg := evt.getErrorMessage || wf_core.newline ||
1413: wf_core.translate('WF_EVTNAME_NULL');
1414: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));
1415: END IF;
1416: end if;
1417:
1418: -- Check if we are doing deferred processing

Line 1509: if (wf_core.error_name = 'WFE_DISPATCH_RULE_ERR') then

1505: rollback to bes_before_dequeue_qh;
1506:
1507: -- Error WFE_DISPATCH_RULE_ERR already has sufficient info on the error.
1508: -- Just raise it
1509: if (wf_core.error_name = 'WFE_DISPATCH_RULE_ERR') then
1510: raise;
1511: else
1512: wf_core.token('ENAME', evt.event_name);
1513: wf_core.token('EKEY', evt.event_key);

Line 1512: wf_core.token('ENAME', evt.event_name);

1508: -- Just raise it
1509: if (wf_core.error_name = 'WFE_DISPATCH_RULE_ERR') then
1510: raise;
1511: else
1512: wf_core.token('ENAME', evt.event_name);
1513: wf_core.token('EKEY', evt.event_key);
1514: wf_core.token('SQLERRM', sqlerrm);
1515: wf_core.token('SQLCODE', sqlcode);
1516: wf_core.raise('WFE_UNHANDLED_ERROR');

Line 1513: wf_core.token('EKEY', evt.event_key);

1509: if (wf_core.error_name = 'WFE_DISPATCH_RULE_ERR') then
1510: raise;
1511: else
1512: wf_core.token('ENAME', evt.event_name);
1513: wf_core.token('EKEY', evt.event_key);
1514: wf_core.token('SQLERRM', sqlerrm);
1515: wf_core.token('SQLCODE', sqlcode);
1516: wf_core.raise('WFE_UNHANDLED_ERROR');
1517: end if;

Line 1514: wf_core.token('SQLERRM', sqlerrm);

1510: raise;
1511: else
1512: wf_core.token('ENAME', evt.event_name);
1513: wf_core.token('EKEY', evt.event_key);
1514: wf_core.token('SQLERRM', sqlerrm);
1515: wf_core.token('SQLCODE', sqlcode);
1516: wf_core.raise('WFE_UNHANDLED_ERROR');
1517: end if;
1518: elsif (wf_event.wf_exception_source = 'WF') then

Line 1515: wf_core.token('SQLCODE', sqlcode);

1511: else
1512: wf_core.token('ENAME', evt.event_name);
1513: wf_core.token('EKEY', evt.event_key);
1514: wf_core.token('SQLERRM', sqlerrm);
1515: wf_core.token('SQLCODE', sqlcode);
1516: wf_core.raise('WFE_UNHANDLED_ERROR');
1517: end if;
1518: elsif (wf_event.wf_exception_source = 'WF') then
1519: -- Bug 4207885: Add the handler of exception with source WF

Line 1516: wf_core.raise('WFE_UNHANDLED_ERROR');

1512: wf_core.token('ENAME', evt.event_name);
1513: wf_core.token('EKEY', evt.event_key);
1514: wf_core.token('SQLERRM', sqlerrm);
1515: wf_core.token('SQLCODE', sqlcode);
1516: wf_core.raise('WFE_UNHANDLED_ERROR');
1517: end if;
1518: elsif (wf_event.wf_exception_source = 'WF') then
1519: -- Bug 4207885: Add the handler of exception with source WF
1520: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then

Line 1525: wf_core.token('ENAME', evt.event_name);

1521: wf_log_pkg.string(wf_log_pkg.level_error,
1522: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1523: 'Unexpected Function Error');
1524: end if;
1525: wf_core.token('ENAME', evt.event_name);
1526: wf_core.token('EKEY', evt.event_key);
1527: wf_core.token('SQLERRM', sqlerrm);
1528: wf_core.token('SQLCODE', sqlcode);
1529: wf_core.raise('WFE_UNHANDLED_ERROR');

Line 1526: wf_core.token('EKEY', evt.event_key);

1522: 'wf.plsql.WF_EVENT.listen.dispatch_error',
1523: 'Unexpected Function Error');
1524: end if;
1525: wf_core.token('ENAME', evt.event_name);
1526: wf_core.token('EKEY', evt.event_key);
1527: wf_core.token('SQLERRM', sqlerrm);
1528: wf_core.token('SQLCODE', sqlcode);
1529: wf_core.raise('WFE_UNHANDLED_ERROR');
1530: else

Line 1527: wf_core.token('SQLERRM', sqlerrm);

1523: 'Unexpected Function Error');
1524: end if;
1525: wf_core.token('ENAME', evt.event_name);
1526: wf_core.token('EKEY', evt.event_key);
1527: wf_core.token('SQLERRM', sqlerrm);
1528: wf_core.token('SQLCODE', sqlcode);
1529: wf_core.raise('WFE_UNHANDLED_ERROR');
1530: else
1531: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then

Line 1528: wf_core.token('SQLCODE', sqlcode);

1524: end if;
1525: wf_core.token('ENAME', evt.event_name);
1526: wf_core.token('EKEY', evt.event_key);
1527: wf_core.token('SQLERRM', sqlerrm);
1528: wf_core.token('SQLCODE', sqlcode);
1529: wf_core.raise('WFE_UNHANDLED_ERROR');
1530: else
1531: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1532: wf_log_pkg.string(wf_log_pkg.level_error,

Line 1529: wf_core.raise('WFE_UNHANDLED_ERROR');

1525: wf_core.token('ENAME', evt.event_name);
1526: wf_core.token('EKEY', evt.event_key);
1527: wf_core.token('SQLERRM', sqlerrm);
1528: wf_core.token('SQLCODE', sqlcode);
1529: wf_core.raise('WFE_UNHANDLED_ERROR');
1530: else
1531: if (wf_log_pkg.level_error >= fnd_log.g_current_runtime_level) then
1532: wf_log_pkg.string(wf_log_pkg.level_error,
1533: 'wf.plsql.WF_EVENT.listen.error',

Line 1544: stat := wf_core.translate('WF_SYSTEM_STATUS');

1540: end if;
1541: end;
1542:
1543: -- check system status
1544: stat := wf_core.translate('WF_SYSTEM_STATUS');
1545: if ((stat <> 'ENABLED') AND (st <> stat)) then
1546: exit;
1547: end if;
1548:

Line 1598: wf_core.context('Wf_Event', 'Listen', p_agent_name);

1594: if (wf_event.wf_exception_source = 'WF'
1595: OR wf_event.wf_exception_source = 'QH') then
1596: raise;
1597: else
1598: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1599: wf_core.raise('WFE_AGENT_NOTEXIST');
1600: end if;
1601: when others then
1602: wf_core.context('Wf_Event', 'Listen', p_agent_name);

Line 1599: wf_core.raise('WFE_AGENT_NOTEXIST');

1595: OR wf_event.wf_exception_source = 'QH') then
1596: raise;
1597: else
1598: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1599: wf_core.raise('WFE_AGENT_NOTEXIST');
1600: end if;
1601: when others then
1602: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1603: -- 7828862 Restore apps context from cached values

Line 1602: wf_core.context('Wf_Event', 'Listen', p_agent_name);

1598: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1599: wf_core.raise('WFE_AGENT_NOTEXIST');
1600: end if;
1601: when others then
1602: wf_core.context('Wf_Event', 'Listen', p_agent_name);
1603: -- 7828862 Restore apps context from cached values
1604: wfa_sec.Restore_Ctx();
1605: raise;
1606: end Listen;

Line 1659: wf_core.get_error(errname, errmsg, errstack);

1655: errbuf := '';
1656: retcode := '0';
1657: exception
1658: when others then
1659: wf_core.get_error(errname, errmsg, errstack);
1660: if (errmsg is not null) then
1661: errbuf := errmsg;
1662: else
1663: errbuf := sqlerrm;

Line 1699: g_local_system_guid := hextoraw(WF_CORE.Translate('WF_SYSTEM_GUID'));

1695: -- Confirm that p_agent_name includes a transactional queue.
1696: -- Tuned and separated sql statement for better performance
1697: -- restricting Listen() to local system.
1698: if (WF_EVENT.g_local_system_guid is NULL) then
1699: g_local_system_guid := hextoraw(WF_CORE.Translate('WF_SYSTEM_GUID'));
1700: end if;
1701:
1702: GetAgentDetails(p_agent_name);
1703:

Line 1707: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);

1703:
1704: -- get agent details for local system
1705: l_agent_obj := wf_bes_cache.GetAgentByName(p_agent_name, null);
1706: if (l_agent_obj is null) then
1707: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1708: wf_core.raise('WFE_AGENT_NOTEXIST');
1709: end if;
1710: qh := l_agent_obj.queue_handler;
1711: agt := l_agent_obj.guid;

Line 1708: wf_core.raise('WFE_AGENT_NOTEXIST');

1704: -- get agent details for local system
1705: l_agent_obj := wf_bes_cache.GetAgentByName(p_agent_name, null);
1706: if (l_agent_obj is null) then
1707: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1708: wf_core.raise('WFE_AGENT_NOTEXIST');
1709: end if;
1710: qh := l_agent_obj.queue_handler;
1711: agt := l_agent_obj.guid;
1712:

Line 1716: WF_CORE.Context('Wf_Event', 'Listen_GRP', p_agent_name);

1712:
1713:
1714: if (WF_EVENT.g_message_grouping <> 'TRANSACTIONAL') then
1715: --This is not a transactional queue.
1716: WF_CORE.Context('Wf_Event', 'Listen_GRP', p_agent_name);
1717: WF_CORE.Token('AGENT', p_agent_name);
1718: WF_CORE.Token('API', 'WF_EVENT.Listen');
1719: WF_CORE.Raise('WFE_NONTRXN_QUEUE');
1720: end if;

Line 1717: WF_CORE.Token('AGENT', p_agent_name);

1713:
1714: if (WF_EVENT.g_message_grouping <> 'TRANSACTIONAL') then
1715: --This is not a transactional queue.
1716: WF_CORE.Context('Wf_Event', 'Listen_GRP', p_agent_name);
1717: WF_CORE.Token('AGENT', p_agent_name);
1718: WF_CORE.Token('API', 'WF_EVENT.Listen');
1719: WF_CORE.Raise('WFE_NONTRXN_QUEUE');
1720: end if;
1721:

Line 1718: WF_CORE.Token('API', 'WF_EVENT.Listen');

1714: if (WF_EVENT.g_message_grouping <> 'TRANSACTIONAL') then
1715: --This is not a transactional queue.
1716: WF_CORE.Context('Wf_Event', 'Listen_GRP', p_agent_name);
1717: WF_CORE.Token('AGENT', p_agent_name);
1718: WF_CORE.Token('API', 'WF_EVENT.Listen');
1719: WF_CORE.Raise('WFE_NONTRXN_QUEUE');
1720: end if;
1721:
1722: --Verifying that the system is not disabled.

Line 1719: WF_CORE.Raise('WFE_NONTRXN_QUEUE');

1715: --This is not a transactional queue.
1716: WF_CORE.Context('Wf_Event', 'Listen_GRP', p_agent_name);
1717: WF_CORE.Token('AGENT', p_agent_name);
1718: WF_CORE.Token('API', 'WF_EVENT.Listen');
1719: WF_CORE.Raise('WFE_NONTRXN_QUEUE');
1720: end if;
1721:
1722: --Verifying that the system is not disabled.
1723: if (wf_event.local_system_status = 'DISABLED' OR

Line 1724: wf_core.database_current_edition <> wf_core.database_default_edition) then

1720: end if;
1721:
1722: --Verifying that the system is not disabled.
1723: if (wf_event.local_system_status = 'DISABLED' OR
1724: wf_core.database_current_edition <> wf_core.database_default_edition) then
1725: return;
1726: end if;
1727:
1728: /*

Line 1733: WF_CORE.Clear; --Clear any tokens that were set from the previous

1729: ** We need to explicitly make sure that if someones Queue Handler
1730: ** blows up we rollback the transaction, just in case they don't
1731: */
1732: loop --Outer loop to process all transactions.
1733: WF_CORE.Clear; --Clear any tokens that were set from the previous
1734: --transaction dequeue.
1735:
1736: begin --We will begin processing a transaction (message group).
1737: savepoint trxn_start;

Line 1802: evt_errmsg := evt.getErrorMessage || wf_core.newline ||

1798:
1799: if (evt.getEventName) is NULL then
1800: evt.setEventName('UNEXPECTED_ERROR');
1801: evt.setEventKey('UNEXPERR');
1802: evt_errmsg := evt.getErrorMessage || wf_core.newline ||
1803: wf_core.translate('WF_EVTNAME_NULL');
1804: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));
1805: END IF;
1806:

Line 1803: wf_core.translate('WF_EVTNAME_NULL');

1799: if (evt.getEventName) is NULL then
1800: evt.setEventName('UNEXPECTED_ERROR');
1801: evt.setEventKey('UNEXPERR');
1802: evt_errmsg := evt.getErrorMessage || wf_core.newline ||
1803: wf_core.translate('WF_EVTNAME_NULL');
1804: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));
1805: END IF;
1806:
1807:

Line 1804: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));

1800: evt.setEventName('UNEXPECTED_ERROR');
1801: evt.setEventKey('UNEXPERR');
1802: evt_errmsg := evt.getErrorMessage || wf_core.newline ||
1803: wf_core.translate('WF_EVTNAME_NULL');
1804: evt.setErrorMessage(wf_core.translate('WF_EVTNAME_NULL'));
1805: END IF;
1806:
1807:
1808: -- Begin Dispatching the event message.

Line 1825: stat := wf_core.translate('WF_SYSTEM_STATUS');

1821:
1822: end;
1823:
1824: -- check system status --
1825: stat := wf_core.translate('WF_SYSTEM_STATUS');
1826: if ((stat <> 'ENABLED') AND (st <> stat)) then
1827: exit;
1828: end if;
1829:

Line 1925: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);

1921: if (wf_event.wf_exception_source = 'WF'
1922: OR wf_event.wf_exception_source = 'QH') then
1923: raise;
1924: else
1925: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1926: wf_core.raise('WFE_AGENT_NOTEXIST');
1927: end if;
1928: when others then
1929: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);

Line 1926: wf_core.raise('WFE_AGENT_NOTEXIST');

1922: OR wf_event.wf_exception_source = 'QH') then
1923: raise;
1924: else
1925: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1926: wf_core.raise('WFE_AGENT_NOTEXIST');
1927: end if;
1928: when others then
1929: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1930: raise;

Line 1929: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);

1925: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1926: wf_core.raise('WFE_AGENT_NOTEXIST');
1927: end if;
1928: when others then
1929: wf_core.context('Wf_Event', 'Listen_GRP', p_agent_name);
1930: raise;
1931: end;
1932:
1933: ---------------------------------------------------------------------------

Line 1951: wf_core.get_error(errname, errmsg, errstack);

1947: errbuf := '';
1948: retcode := '0';
1949: exception
1950: when others then
1951: wf_core.get_error(errname, errmsg, errstack);
1952: if (errmsg is not null) then
1953: errbuf := errmsg;
1954: else
1955: errbuf := sqlerrm;

Line 2055: wf_core.context('Wf_Event', 'Dispatch', l_event_name);

2051: exception
2052: when others then
2053: wf_event.setErrorInfo(p_event, 'ERROR');
2054: wf_event.saveErrorToQueue(p_event);
2055: wf_core.context('Wf_Event', 'Dispatch', l_event_name);
2056: raise;
2057: end;
2058:
2059: --

Line 2090: wf_core.context('Wf_Event', 'Dispatch', l_event_name);

2086: --Should we save the error to queue since it is WF error?
2087: when others then
2088: wf_event.setErrorInfo(p_event, 'ERROR');
2089: wf_event.saveErrorToQueue(p_event);
2090: wf_core.context('Wf_Event', 'Dispatch', l_event_name);
2091: raise;
2092: end;
2093: end;
2094:

Line 2234: WF_CORE.Context('Wf_Event', 'Dispatch', l_event_name);

2230: exception
2231: when others then
2232: -- Unexpected Error happened in dispatch_internal
2233: if (WF_EVENT.g_message_grouping = 'TRANSACTIONAL') then
2234: WF_CORE.Context('Wf_Event', 'Dispatch', l_event_name);
2235: else
2236: rollback to wf_dispatch_savepoint;
2237: p_event.setErrorSubscription(eguid);
2238: if (wf_event.wf_exception_source <> 'RULE') then

Line 2244: wf_core.context('Wf_Event', 'Dispatch', l_event_name);

2240: wf_event.setErrorInfo(p_event, 'UNEXPECTED');
2241: -- Unexpected Exception should be thrown up instead of
2242: -- being enqueued to error queue.
2243: -- wf_event.saveErrorToQueue(p_event);
2244: wf_core.context('Wf_Event', 'Dispatch', l_event_name);
2245: end if;
2246: end if;
2247: raise;
2248: end;

Line 2311: wf_core.context('Wf_Event', 'Enqueue', p_event.getEventName(), qh);

2307: 'End executing queue handler - '||qh, false);
2308: end if;
2309: exception
2310: when others then
2311: wf_core.context('Wf_Event', 'Enqueue', p_event.getEventName(), qh);
2312: wf_core.token('FUNCTION_NAME', qh||'.enqueue()');
2313: --wf_core.raise('WF_EXT_FUNCTION');
2314: raise;
2315: end;

Line 2312: wf_core.token('FUNCTION_NAME', qh||'.enqueue()');

2308: end if;
2309: exception
2310: when others then
2311: wf_core.context('Wf_Event', 'Enqueue', p_event.getEventName(), qh);
2312: wf_core.token('FUNCTION_NAME', qh||'.enqueue()');
2313: --wf_core.raise('WF_EXT_FUNCTION');
2314: raise;
2315: end;
2316: ---------------------------------------------------------------------------

Line 2313: --wf_core.raise('WF_EXT_FUNCTION');

2309: exception
2310: when others then
2311: wf_core.context('Wf_Event', 'Enqueue', p_event.getEventName(), qh);
2312: wf_core.token('FUNCTION_NAME', qh||'.enqueue()');
2313: --wf_core.raise('WF_EXT_FUNCTION');
2314: raise;
2315: end;
2316: ---------------------------------------------------------------------------
2317: /*

Line 2378: wf_core.context('Wf_Event', 'Dequeue', p_agent_guid);

2374:
2375: p_queue_handler := qh;
2376: exception
2377: when others then
2378: wf_core.context('Wf_Event', 'Dequeue', p_agent_guid);
2379: wf_core.token('FUNCTION_NAME', qh||'.dequeue()');
2380: --wf_core.raise('WF_EXT_FUNCTION');
2381: raise;
2382: end;

Line 2379: wf_core.token('FUNCTION_NAME', qh||'.dequeue()');

2375: p_queue_handler := qh;
2376: exception
2377: when others then
2378: wf_core.context('Wf_Event', 'Dequeue', p_agent_guid);
2379: wf_core.token('FUNCTION_NAME', qh||'.dequeue()');
2380: --wf_core.raise('WF_EXT_FUNCTION');
2381: raise;
2382: end;
2383: ---------------------------------------------------------------------------

Line 2380: --wf_core.raise('WF_EXT_FUNCTION');

2376: exception
2377: when others then
2378: wf_core.context('Wf_Event', 'Dequeue', p_agent_guid);
2379: wf_core.token('FUNCTION_NAME', qh||'.dequeue()');
2380: --wf_core.raise('WF_EXT_FUNCTION');
2381: raise;
2382: end;
2383: ---------------------------------------------------------------------------
2384: /*

Line 2524: wf_core.context('Wf_Event', 'SetDispatchMode', p_mode);

2520: wf_event.phase_maxthreshold := 100;
2521: end if;
2522: exception
2523: when others then
2524: wf_core.context('Wf_Event', 'SetDispatchMode', p_mode);
2525: raise;
2526: end SetDispatchMode;
2527: ---------------------------------------------------------------------------
2528: /*

Line 2586: wf_core.context('Wf_Event', 'DeferEvent', p_event.getEventName(),

2582: wf_event.enqueue(p_event,defagent);
2583:
2584: exception
2585: when others then
2586: wf_core.context('Wf_Event', 'DeferEvent', p_event.getEventName(),
2587: p_event.getEventKey());
2588: raise;
2589: end DeferEvent;
2590: ---------------------------------------------------------------------------

Line 2644: wf_core.context('Wf_Event', 'DeferEventToJava', p_event.getEventName(),

2640: end if;
2641:
2642: exception
2643: when others then
2644: wf_core.context('Wf_Event', 'DeferEventToJava', p_event.getEventName(),
2645: p_event.getEventKey());
2646: raise;
2647: end DeferEventToJava;
2648: ---------------------------------------------------------------------------

Line 2734: wf_core.context('Wf_Event', 'GetDeferEventCtx','Sub guid is ' || subguid);

2730: exception
2731: /* Bug 2210085 */
2732: when no_data_found then
2733: /*
2734: wf_core.context('Wf_Event', 'GetDeferEventCtx','Sub guid is ' || subguid);
2735: wf_core.token('SGUID', subguid);
2736: wf_core.raise('WFE_SUB_DELETED');
2737: */
2738: raise;

Line 2735: wf_core.token('SGUID', subguid);

2731: /* Bug 2210085 */
2732: when no_data_found then
2733: /*
2734: wf_core.context('Wf_Event', 'GetDeferEventCtx','Sub guid is ' || subguid);
2735: wf_core.token('SGUID', subguid);
2736: wf_core.raise('WFE_SUB_DELETED');
2737: */
2738: raise;
2739:

Line 2736: wf_core.raise('WFE_SUB_DELETED');

2732: when no_data_found then
2733: /*
2734: wf_core.context('Wf_Event', 'GetDeferEventCtx','Sub guid is ' || subguid);
2735: wf_core.token('SGUID', subguid);
2736: wf_core.raise('WFE_SUB_DELETED');
2737: */
2738: raise;
2739:
2740: when others then

Line 2741: wf_core.context('Wf_Event', 'GetDeferEventCtx', p_event.getEventName(),

2737: */
2738: raise;
2739:
2740: when others then
2741: wf_core.context('Wf_Event', 'GetDeferEventCtx', p_event.getEventName(),
2742: p_event.getEventKey());
2743: raise;
2744: end GetDeferEventCtx;
2745: ---------------------------------------------------------------------------

Line 2758: wf_core.context('Wf_Event', 'SetAccountName');

2754: into wf_event.account_name
2755: from sys.dual;
2756: exception
2757: when others then
2758: wf_core.context('Wf_Event', 'SetAccountName');
2759: raise;
2760: end SetAccountName;
2761: ---------------------------------------------------------------------------
2762: --

Line 2982: wf_core.tag_db_session(wf_core.conn_tag_bes, p_event_name);

2978: event wf_event_t;
2979: begin
2980:
2981: -- Bug 9370391: tag DB session for BES module
2982: wf_core.tag_db_session(wf_core.conn_tag_bes, p_event_name);
2983:
2984: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
2985: wf_log_pkg.string(wf_log_pkg.level_procedure,
2986: 'wf.plsql.WF_EVENT.raise3.Begin',

Line 3007: wf_core.context('Wf_Event', 'raise', p_event_name, p_event_key);

3003: 'wf.plsql.WF_EVENT.raise3.recursion_error',
3004: 'Recursion error raised. Nested raise count exceeded threshold');
3005: end if;
3006:
3007: wf_core.context('Wf_Event', 'raise', p_event_name, p_event_key);
3008: wf_core.raise('WFE_RECURSION');
3009: end if;
3010:
3011: --Create the event that is to be raised

Line 3008: wf_core.raise('WFE_RECURSION');

3004: 'Recursion error raised. Nested raise count exceeded threshold');
3005: end if;
3006:
3007: wf_core.context('Wf_Event', 'raise', p_event_name, p_event_key);
3008: wf_core.raise('WFE_RECURSION');
3009: end if;
3010:
3011: --Create the event that is to be raised
3012: wf_event_t.initialize(event);

Line 3128: wf_core.context('Wf_Event', 'GetLocalSystemName');

3124: system_name := wf_event.local_system_name;
3125: system_status := wf_event.local_system_status;
3126: exception
3127: when others then
3128: wf_core.context('Wf_Event', 'GetLocalSystemName');
3129: end GetLocalSystemInfo;
3130: ---------------------------------------------------------------------------
3131: /*
3132: ** GetSourceAgentGUID -

Line 3157: wf_core.context('Wf_Event', 'GetSourceAgentGUID', agent_name);

3153: agent_guid := null;
3154: end if;
3155: exception
3156: when others then
3157: wf_core.context('Wf_Event', 'GetSourceAgentGUID', agent_name);
3158: raise;
3159: end GetSourceAgentGUID;
3160: ---------------------------------------------------------------------------
3161: /*

Line 3297: --schema := wf_core.translate('WF_SCHEMA');

3293: --Enable the deferred and error queues for
3294: --enqueue and dequeue incase they are disabled
3295: --In any cases, the WF_DEFERRED, WF_ERROR, WF_JAVA_ERROR and WF_JAVA_DEFERRED
3296: --must be started.
3297: --schema := wf_core.translate('WF_SCHEMA');
3298: --Bug 3659756, no longer start fixed name queues.
3299: /*
3300: for q_name in q_disabled (wf_event.schema_name) loop
3301: DBMS_AQADM.START_QUEUE(wf_event.schema_name||'.'||q_name.name);

Line 3337: wf_core.context('Wf_Event', 'StartAgent', agent_name);

3333: 'Starting Agents');
3334: end if;
3335: exception
3336: when no_data_found then
3337: wf_core.context('Wf_Event', 'StartAgent', agent_name);
3338: wf_core.raise('WFE_AGENT_NOTEXIST');
3339: when others then
3340: wf_core.context('Wf_Event', 'StartAgent', agent_name);
3341: raise;

Line 3338: wf_core.raise('WFE_AGENT_NOTEXIST');

3334: end if;
3335: exception
3336: when no_data_found then
3337: wf_core.context('Wf_Event', 'StartAgent', agent_name);
3338: wf_core.raise('WFE_AGENT_NOTEXIST');
3339: when others then
3340: wf_core.context('Wf_Event', 'StartAgent', agent_name);
3341: raise;
3342: end StartAgent;

Line 3340: wf_core.context('Wf_Event', 'StartAgent', agent_name);

3336: when no_data_found then
3337: wf_core.context('Wf_Event', 'StartAgent', agent_name);
3338: wf_core.raise('WFE_AGENT_NOTEXIST');
3339: when others then
3340: wf_core.context('Wf_Event', 'StartAgent', agent_name);
3341: raise;
3342: end StartAgent;
3343: ---------------------------------------------------------------------------
3344: /*

Line 3421: l_parameters := replace(l_parameters, wf_core.newline,' ');

3417: begin
3418: l_parameters := p_parameters;
3419:
3420: if (l_parameters is not null) then
3421: l_parameters := replace(l_parameters, wf_core.newline,' ');
3422: l_parameters := replace(l_parameters, wf_core.tab,' ');
3423: l_parameters := replace(l_parameters, wf_core.cr,'');
3424: l_parameters := l_parameters||' ';
3425:

Line 3422: l_parameters := replace(l_parameters, wf_core.tab,' ');

3418: l_parameters := p_parameters;
3419:
3420: if (l_parameters is not null) then
3421: l_parameters := replace(l_parameters, wf_core.newline,' ');
3422: l_parameters := replace(l_parameters, wf_core.tab,' ');
3423: l_parameters := replace(l_parameters, wf_core.cr,'');
3424: l_parameters := l_parameters||' ';
3425:
3426: l_start:= 1;

Line 3423: l_parameters := replace(l_parameters, wf_core.cr,'');

3419:
3420: if (l_parameters is not null) then
3421: l_parameters := replace(l_parameters, wf_core.newline,' ');
3422: l_parameters := replace(l_parameters, wf_core.tab,' ');
3423: l_parameters := replace(l_parameters, wf_core.cr,'');
3424: l_parameters := l_parameters||' ';
3425:
3426: l_start:= 1;
3427: l_end := length(l_parameters);

Line 3444: wf_core.Context('WF_EVENT', 'GetParamListFromString');

3440: end if;
3441: return l_param_list;
3442: exception
3443: when others then
3444: wf_core.Context('WF_EVENT', 'GetParamListFromString');
3445: raise;
3446: end GetParamListFromString;
3447:
3448: /* PRIVATE

Line 3698: wf_event.local_system_guid := hextoraw(wf_core.translate('WF_SYSTEM_GUID'));

3694: /*
3695: ** SetSystemGlobals - Populates System Global Variables
3696: */
3697: begin
3698: wf_event.local_system_guid := hextoraw(wf_core.translate('WF_SYSTEM_GUID'));
3699:
3700: wf_event.local_system_status := wf_core.translate('WF_SYSTEM_STATUS');
3701:
3702: select name into wf_event.local_system_name

Line 3700: wf_event.local_system_status := wf_core.translate('WF_SYSTEM_STATUS');

3696: */
3697: begin
3698: wf_event.local_system_guid := hextoraw(wf_core.translate('WF_SYSTEM_GUID'));
3699:
3700: wf_event.local_system_status := wf_core.translate('WF_SYSTEM_STATUS');
3701:
3702: select name into wf_event.local_system_name
3703: from wf_systems
3704: where guid = wf_event.local_system_guid;

Line 3706: wf_event.schema_name := wf_core.translate('WF_SCHEMA');

3702: select name into wf_event.local_system_name
3703: from wf_systems
3704: where guid = wf_event.local_system_guid;
3705: ---------------------------------------------------------------------------
3706: wf_event.schema_name := wf_core.translate('WF_SCHEMA');
3707:
3708: wf_event.pv_last_agent_name := ' ';
3709: wf_event.pv_last_queue_name := ' ';
3710: wf_event.pv_last_schema_name := ' ';