APPS.ECX_INBOUND_ENGINE_QH dependencies on DBMS_AQ

Line 20: v_dequeueoptions dbms_aq.dequeue_options_t;

16: x_from_agt wf_agent_t := wf_agent_t(null,null);
17: x_to_agt wf_agent_t := wf_agent_t(null,null);
18:
19: v_message system.ecx_inengobj;
20: v_dequeueoptions dbms_aq.dequeue_options_t;
21: v_messageproperties dbms_aq.message_properties_t;
22: v_msgid raw(16);
23: l_module varchar2(2000);
24: v_log_enabled_appl varchar2(1);

Line 21: v_messageproperties dbms_aq.message_properties_t;

17: x_to_agt wf_agent_t := wf_agent_t(null,null);
18:
19: v_message system.ecx_inengobj;
20: v_dequeueoptions dbms_aq.dequeue_options_t;
21: v_messageproperties dbms_aq.message_properties_t;
22: v_msgid raw(16);
23: l_module varchar2(2000);
24: v_log_enabled_appl varchar2(1);
25: v_log_enabled_site varchar2(1);

Line 95: dbms_aq.dequeue (

91: server_id=>null);
92: if (v_log_enabled_site='Y' AND (v_log_module_site like 'ecx%'or v_log_module_site = '%')) then fnd_global.apps_initialize(0,20420,0);
93: end if;
94: end if;
95: dbms_aq.dequeue (
96: queue_name => x_queue_name,
97: dequeue_options => v_dequeueoptions,
98: message_properties => v_messageproperties,
99: payload => v_message,

Line 146: x_enqueue_options dbms_aq.enqueue_options_t;

142: x_to_agent_name varchar2(30) := p_event.GetToAgent().GetName();
143: x_to_system_name varchar2(30) := p_event.GetToAgent().GetSystem();
144: x_out_queue varchar2(80);
145: x_to_queue varchar2(80);
146: x_enqueue_options dbms_aq.enqueue_options_t;
147: x_message_properties dbms_aq.message_properties_t;
148: v_msgid RAW(16);
149: v_message SYSTEM.ECX_INENGOBJ ;
150: x_trigger_id number;

Line 147: x_message_properties dbms_aq.message_properties_t;

143: x_to_system_name varchar2(30) := p_event.GetToAgent().GetSystem();
144: x_out_queue varchar2(80);
145: x_to_queue varchar2(80);
146: x_enqueue_options dbms_aq.enqueue_options_t;
147: x_message_properties dbms_aq.message_properties_t;
148: v_msgid RAW(16);
149: v_message SYSTEM.ECX_INENGOBJ ;
150: x_trigger_id number;
151: l_module varchar2(2000);

Line 211: DBMS_AQ.ENQUEUE(

207: */
208: x_message_properties.priority := p_event.GetPriority();
209:
210: begin
211: DBMS_AQ.ENQUEUE(
212: queue_name => x_out_queue,
213: enqueue_options => x_enqueue_options,
214: message_properties => x_message_properties,
215: payload => v_message,

Line 247: 'finished calling dbms_aq.enqueue');

243: end;
244:
245: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
246: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module || '.end',
247: 'finished calling dbms_aq.enqueue');
248: end if;
249:
250: exception
251: when others then