DBA Data[Home] [Help]

APPS.ECX_OUT_WF_QH dependencies on ECX_OUT_WF_QH

Line 1: PACKAGE BODY ecx_out_wf_qh as

1: PACKAGE BODY ecx_out_wf_qh as
2: -- $Header: ECXOWFQB.pls 115.14 2004/06/01 21:19:23 mtai ship $
3:
4:
5: PROCEDURE Dequeue(p_agent_guid in RAW, p_event out NOCOPY WF_EVENT_T)

Line 23: l_module := 'ecx.plsq.ecx_out_wf_qh.dequeue';

19: x_to_agt wf_agent_t := wf_agent_t(null,null);
20: l_module varchar2(2000);
21:
22: begin
23: l_module := 'ecx.plsq.ecx_out_wf_qh.dequeue';
24: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
25: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module ||'.begin',
26: 'getting queue details');
27: end if;

Line 50: x_dequeue_options.navigation := ecx_out_wf_qh.navigation;

46:
47: wf_event_t.initialize(p_event);
48:
49: x_dequeue_options.wait := dbms_aq.no_wait;
50: x_dequeue_options.navigation := ecx_out_wf_qh.navigation;
51:
52: begin
53: dbms_aq.dequeue
54: (

Line 62: ecx_out_wf_qh.navigation := dbms_aq.next_message;

58: payload => x_ecxmsg,
59: msgid => x_msgid
60: );
61:
62: ecx_out_wf_qh.navigation := dbms_aq.next_message;
63:
64: p_event.priority := 1;
65: p_event.event_name := 'oracle.apps.ecx.inbound.message.receive';
66: p_event.event_key := x_ecxmsg.document_number;

Line 108: ecx_out_wf_qh.navigation := dbms_aq.first_message;

104: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
105: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
106: 'No more messages in dequeue.');
107: end if;
108: ecx_out_wf_qh.navigation := dbms_aq.first_message;
109: p_event := NULL;
110: return;
111: end;
112:

Line 115: Wf_Core.Context('ECX_OUT_WF_QH', 'Dequeue', x_queue_name);

111: end;
112:
113: exception
114: when others then
115: Wf_Core.Context('ECX_OUT_WF_QH', 'Dequeue', x_queue_name);
116: raise;
117: end Dequeue;
118:
119:

Line 138: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue.create_ecxmsg';

134: l_module varchar2(2000);
135:
136: begin
137:
138: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue.create_ecxmsg';
139: -- loop through the parameter list and construct x_ecxmsg object
140: i_param_list := p_event.getParameterList();
141: if (i_param_list is null) then
142: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then

Line 147: --MLS ecx_out_wf_qh.retmsg := 'Parameter List cannot be null';

143: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,
144: 'event object parameter list in empty');
145: end if;
146:
147: --MLS ecx_out_wf_qh.retmsg := 'Parameter List cannot be null';
148: ecx_out_wf_qh.retmsg :='ECX_PARAM_LIST_NOT_NULL';
149: ecx_out_wf_qh.retcode := 2;
150: raise queue_handler_exit;
151: else

Line 148: ecx_out_wf_qh.retmsg :='ECX_PARAM_LIST_NOT_NULL';

144: 'event object parameter list in empty');
145: end if;
146:
147: --MLS ecx_out_wf_qh.retmsg := 'Parameter List cannot be null';
148: ecx_out_wf_qh.retmsg :='ECX_PARAM_LIST_NOT_NULL';
149: ecx_out_wf_qh.retcode := 2;
150: raise queue_handler_exit;
151: else
152: x_ecxmsg := SYSTEM.ecxmsg(null, null, null, null, null, null, null, null, null,

Line 149: ecx_out_wf_qh.retcode := 2;

145: end if;
146:
147: --MLS ecx_out_wf_qh.retmsg := 'Parameter List cannot be null';
148: ecx_out_wf_qh.retmsg :='ECX_PARAM_LIST_NOT_NULL';
149: ecx_out_wf_qh.retcode := 2;
150: raise queue_handler_exit;
151: else
152: x_ecxmsg := SYSTEM.ecxmsg(null, null, null, null, null, null, null, null, null,
153: null, null, null, null, null, null, null, null, null);

Line 222: ecx_out_wf_qh.retmsg := SQLERRM;

218: exception
219: when queue_handler_exit then
220: raise queue_handler_exit;
221: when others then
222: ecx_out_wf_qh.retmsg := SQLERRM;
223: ecx_out_wf_qh.retcode := 2;
224: raise queue_handler_exit;
225: end create_ecxmsg;
226:

Line 223: ecx_out_wf_qh.retcode := 2;

219: when queue_handler_exit then
220: raise queue_handler_exit;
221: when others then
222: ecx_out_wf_qh.retmsg := SQLERRM;
223: ecx_out_wf_qh.retcode := 2;
224: raise queue_handler_exit;
225: end create_ecxmsg;
226:
227:

Line 246: l_module := 'ecx.plsq.ecx_out_wf_qh.enqueue.enqueue_msg';

242: l_module varchar2(2000);
243:
244: begin
245:
246: l_module := 'ecx.plsq.ecx_out_wf_qh.enqueue.enqueue_msg';
247: if ( (i_protocol_type = 'HTTP-WM') or (i_protocol_type = 'HTTPS-WM') ) then
248: x_message_properties.correlation := 'WEBMETHODS' ;
249: elsif ((i_protocol_type = 'HTTP') or (i_protocol_type = 'HTTP-OXTA') or
250: (i_protocol_type = 'HTTPS') or (i_protocol_type = 'HTTPS-OXTA') or

Line 300: ecx_out_wf_qh.retmsg := SQLERRM;

296: when others then
297: if dbms_lob.istemporary(l_out_clob) = 1 then
298: dbms_lob.freetemporary(l_out_clob);
299: end if;
300: ecx_out_wf_qh.retmsg := SQLERRM;
301: ecx_out_wf_qh.retcode := 2;
302: raise queue_handler_exit;
303: end enqueue_msg;
304:

Line 301: ecx_out_wf_qh.retcode := 2;

297: if dbms_lob.istemporary(l_out_clob) = 1 then
298: dbms_lob.freetemporary(l_out_clob);
299: end if;
300: ecx_out_wf_qh.retmsg := SQLERRM;
301: ecx_out_wf_qh.retcode := 2;
302: raise queue_handler_exit;
303: end enqueue_msg;
304:
305:

Line 326: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue';

322: select ecx_trigger_id_s.NEXTVAL
323: from dual;
324:
325: begin
326: l_module := 'ecx.plsql.ecx_out_wf_qh.enqueue';
327: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
328: wf_log_pkg.string(wf_log_pkg.level_procedure, l_module ||'.begin',
329: 'Enqueue Message');
330: end if;

Line 356: ecx_out_wf_qh.enqueue_msg(

352:
353: create_ecxmsg (p_event, x_ecxmsg);
354:
355: -- enqueue the message
356: ecx_out_wf_qh.enqueue_msg(
357: x_out_queue => x_out_queue,
358: i_protocol_type => x_ecxmsg.protocol_type,
359: x_ecxmsg => x_ecxmsg,
360: x_msgid => x_msgid

Line 364: ecx_out_wf_qh.msgid := x_msgid;

360: x_msgid => x_msgid
361: );
362:
363: -- set msgid
364: ecx_out_wf_qh.msgid := x_msgid;
365: wf_event.g_msgid := x_msgid;
366:
367: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
368: wf_log_pkg.string(wf_log_pkg.level_statement, l_module,

Line 406: wf_core.context('ECX_OUT_WF_QH', 'Enqueue', x_out_queue, ecx_debug.getMessage(ecx_out_wf_qh.retmsg,

402: end if;
403: */
404: exception
405: when queue_handler_exit then
406: wf_core.context('ECX_OUT_WF_QH', 'Enqueue', x_out_queue, ecx_debug.getMessage(ecx_out_wf_qh.retmsg,
407: ecx_utils.i_errparams), ecx_out_wf_qh.retcode);
408: raise;
409:
410: when others then

Line 407: ecx_utils.i_errparams), ecx_out_wf_qh.retcode);

403: */
404: exception
405: when queue_handler_exit then
406: wf_core.context('ECX_OUT_WF_QH', 'Enqueue', x_out_queue, ecx_debug.getMessage(ecx_out_wf_qh.retmsg,
407: ecx_utils.i_errparams), ecx_out_wf_qh.retcode);
408: raise;
409:
410: when others then
411: ecx_out_wf_qh.retmsg := SQLERRM;

Line 411: ecx_out_wf_qh.retmsg := SQLERRM;

407: ecx_utils.i_errparams), ecx_out_wf_qh.retcode);
408: raise;
409:
410: when others then
411: ecx_out_wf_qh.retmsg := SQLERRM;
412: ecx_out_wf_qh.retcode := 2;
413: raise queue_handler_exit;
414: end Enqueue;
415:

Line 412: ecx_out_wf_qh.retcode := 2;

408: raise;
409:
410: when others then
411: ecx_out_wf_qh.retmsg := SQLERRM;
412: ecx_out_wf_qh.retcode := 2;
413: raise queue_handler_exit;
414: end Enqueue;
415:
416: end ECX_OUT_WF_QH;

Line 416: end ECX_OUT_WF_QH;

412: ecx_out_wf_qh.retcode := 2;
413: raise queue_handler_exit;
414: end Enqueue;
415:
416: end ECX_OUT_WF_QH;
417: