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 94: dbms_aq.dequeue (

90: server_id=>null);
91: 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);
92: end if;
93: end if;
94: dbms_aq.dequeue (
95: queue_name => x_queue_name,
96: dequeue_options => v_dequeueoptions,
97: message_properties => v_messageproperties,
98: payload => v_message,

Line 145: x_enqueue_options dbms_aq.enqueue_options_t;

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

Line 146: x_message_properties dbms_aq.message_properties_t;

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

Line 210: DBMS_AQ.ENQUEUE(

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

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

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