26: v_log_module_appl varchar2(240);
27: v_log_module_site varchar2(240);
28: begin
29: l_module := 'ecx.plsql.ecx_inbound_engine_qh';
30: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
31: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module || '.begin',
32: 'in dequeue');
33: end if;
34:
27: v_log_module_site varchar2(240);
28: begin
29: l_module := 'ecx.plsql.ecx_inbound_engine_qh';
30: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
31: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module || '.begin',
32: 'in dequeue');
33: end if;
34:
35: select upper(queue_name), upper(name), system_guid
45: x_from_agt := wf_agent_t(x_agent_name, x_sys_name);
46: x_to_agt := wf_agent_t(x_agent_name, x_sys_name);
47:
48: BEGIN
49: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
50: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
51: 'p_agent_guid' ||hextoraw(p_agent_guid));
52: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
53: 'System: ' || x_sys_name);
46: x_to_agt := wf_agent_t(x_agent_name, x_sys_name);
47:
48: BEGIN
49: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
50: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
51: 'p_agent_guid' ||hextoraw(p_agent_guid));
52: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
53: 'System: ' || x_sys_name);
54: end if;
48: BEGIN
49: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
50: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
51: 'p_agent_guid' ||hextoraw(p_agent_guid));
52: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
53: 'System: ' || x_sys_name);
54: end if;
55:
56: v_dequeueoptions.wait := 1;
107: p_event.from_agent := x_from_agt ;
108: p_event.to_agent := x_to_agt;
109: p_event.send_date := sysdate;
110:
111: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
112: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
113: 'After Dequeue. Message Id: ' || x_msgid);
114: end if;
115:
108: p_event.to_agent := x_to_agt;
109: p_event.send_date := sysdate;
110:
111: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
112: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
113: 'After Dequeue. Message Id: ' || x_msgid);
114: end if;
115:
116: EXCEPTION
114: end if;
115:
116: EXCEPTION
117: when no_messages then
118: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
119: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
120: 'No more messages in dequeue.');
121: end if;
122: p_event := NULL;
115:
116: EXCEPTION
117: when no_messages then
118: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
119: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
120: 'No more messages in dequeue.');
121: end if;
122: p_event := NULL;
123: return;
124: END;
125: exception
126: when others then
127: rollback to before_dequeue;
128: if (wf_log_pkg.level_unexpected >= fnd_log.g_current_runtime_level) then
129: wf_log_pkg.string(wf_log_pkg.level_unexpected, l_module,
130: substr(sqlerrm, 1,2000));
131: end if;
132: Wf_Core.Context('Wf_Event_ECXMSG_QH', 'Dequeue', x_queue_name);
125: exception
126: when others then
127: rollback to before_dequeue;
128: if (wf_log_pkg.level_unexpected >= fnd_log.g_current_runtime_level) then
129: wf_log_pkg.string(wf_log_pkg.level_unexpected, l_module,
130: substr(sqlerrm, 1,2000));
131: end if;
132: Wf_Core.Context('Wf_Event_ECXMSG_QH', 'Dequeue', x_queue_name);
133: raise;
157:
158:
159: begin
160: l_module := 'ecx.plsql.ecx_inbound_engine_qh.enqueue';
161: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
162: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module || '.begin',
163: 'in enqueue');
164: end if;
165:
158:
159: begin
160: l_module := 'ecx.plsql.ecx_inbound_engine_qh.enqueue';
161: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
162: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module || '.begin',
163: 'in enqueue');
164: end if;
165:
166: -- Determine the out queue
190: fetch c_ecx_trigger_id into x_trigger_id;
191: close c_ecx_trigger_id;
192: end if;
193:
194: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
195: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
196: 'Trigger Id: ' || x_trigger_id);
197: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
198: 'Message Id: ' || v_message.msgid);
191: close c_ecx_trigger_id;
192: end if;
193:
194: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
195: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
196: 'Trigger Id: ' || x_trigger_id);
197: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
198: 'Message Id: ' || v_message.msgid);
199: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
193:
194: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
195: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
196: 'Trigger Id: ' || x_trigger_id);
197: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
198: 'Message Id: ' || v_message.msgid);
199: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
200: 'Debug Mode: ' || v_message.debug_mode);
201: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
195: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
196: 'Trigger Id: ' || x_trigger_id);
197: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
198: 'Message Id: ' || v_message.msgid);
199: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
200: 'Debug Mode: ' || v_message.debug_mode);
201: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
202: 'Enqueuing on Queue: ' || x_out_queue);
203: end if;
197: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
198: 'Message Id: ' || v_message.msgid);
199: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
200: 'Debug Mode: ' || v_message.debug_mode);
201: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
202: 'Enqueuing on Queue: ' || x_out_queue);
203: end if;
204:
205: /*
241: );
242:
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:
242:
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