DBA Data[Home] [Help]

APPS.WF_EVENT dependencies on AQ$_AGENT

Line 1009: return sys.aq$_agent is

1005: p_out_system_name in varchar2,
1006: p_to_agent_name in varchar2,
1007: p_to_system_name in varchar2,
1008: p_out_queue_handler in varchar2)
1009: return sys.aq$_agent is
1010: l_to_address WF_AGENTS.ADDRESS%TYPE;
1011: l_to_protocol WF_AGENTS.PROTOCOL%TYPE;
1012: l_to_queue_name WF_AGENTS.QUEUE_NAME%TYPE;
1013: l_to_protocol_number NUMBER := 0; -- Hard code as SQLNET

Line 1069: return sys.aq$_agent(p_to_agent_name,

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,
1070: l_to_address,
1071: l_to_protocol_number);
1072: exception
1073: WHEN no_data_found THEN

Line 1091: l_recipient_agent sys.aq$_agent;

1087: l_to_type WF_AGENTS.TYPE%TYPE;
1088: l_to_agent_name WF_AGENTS.NAME%TYPE;
1089: l_to_system_name WF_SYSTEMS.NAME%TYPE;
1090: l_out_queue_handler WF_AGENTS.QUEUE_HANDLER%TYPE;
1091: l_recipient_agent sys.aq$_agent;
1092: --Bug 2676549
1093: i number := 0;
1094:
1095: -- bes cache implementation

Line 3353: l_agent sys.aq$_agent;

3349: AS
3350: -- NOTE: This must be done in PL/SQL because in 8i DBMS_AQ.LISTEN is not
3351: -- supported in Java
3352:
3353: l_agent sys.aq$_agent;
3354: l_agent_list dbms_aq.aq$_agent_list_t;
3355:
3356: LISTEN_EXCEPTION exception;
3357:

Line 3354: l_agent_list dbms_aq.aq$_agent_list_t;

3350: -- NOTE: This must be done in PL/SQL because in 8i DBMS_AQ.LISTEN is not
3351: -- supported in Java
3352:
3353: l_agent sys.aq$_agent;
3354: l_agent_list dbms_aq.aq$_agent_list_t;
3355:
3356: LISTEN_EXCEPTION exception;
3357:
3358: pragma exception_init(LISTEN_EXCEPTION, -25254);

Line 3380: l_agent_list(1) := sys.aq$_agent(wf_event.pv_last_agent_name,

3376: -- bug 2897326, agent_list is initialized differently for
3377: -- multi or single consumer queue
3378:
3379: IF wf_event.pv_last_recipients = 'MULTIPLE' THEN
3380: l_agent_list(1) := sys.aq$_agent(wf_event.pv_last_agent_name,
3381: wf_event.pv_last_schema_name || '.' || wf_event.pv_last_queue_name, null);
3382: ELSE
3383: l_agent_list(1) := sys.aq$_agent(null,
3384: wf_event.pv_last_schema_name || '.' || wf_event.pv_last_queue_name, null);

Line 3383: l_agent_list(1) := sys.aq$_agent(null,

3379: IF wf_event.pv_last_recipients = 'MULTIPLE' THEN
3380: l_agent_list(1) := sys.aq$_agent(wf_event.pv_last_agent_name,
3381: wf_event.pv_last_schema_name || '.' || wf_event.pv_last_queue_name, null);
3382: ELSE
3383: l_agent_list(1) := sys.aq$_agent(null,
3384: wf_event.pv_last_schema_name || '.' || wf_event.pv_last_queue_name, null);
3385: END IF;
3386:
3387: -- "Listen" for messages on this queue