DBA Data[Home] [Help]

APPS.IEO_ICSM_AQ_PUB dependencies on DBMS_AQ

Line 21: enqueue_options dbms_aq.enqueue_options_t;

17: )
18: IS
19: l_api_name CONSTANT VARCHAR2(30) := 'ENQUEUE_REQUEST';
20: l_api_version CONSTANT NUMBER := 1.0;
21: enqueue_options dbms_aq.enqueue_options_t;
22: message_properties dbms_aq.message_properties_t;
23: message_handle RAW(16);
24: message SYSTEM.ieo_icsm_msg_type;
25: request_id NUMBER ;

Line 22: message_properties dbms_aq.message_properties_t;

18: IS
19: l_api_name CONSTANT VARCHAR2(30) := 'ENQUEUE_REQUEST';
20: l_api_version CONSTANT NUMBER := 1.0;
21: enqueue_options dbms_aq.enqueue_options_t;
22: message_properties dbms_aq.message_properties_t;
23: message_handle RAW(16);
24: message SYSTEM.ieo_icsm_msg_type;
25: request_id NUMBER ;
26: xml_data_null EXCEPTION;

Line 62: enqueue_options.visibility := DBMS_AQ.IMMEDIATE;

58: select ieo_icsm_aq_s1.nextval into request_id from dual ;
59:
60: message_properties.correlation := p_node_id;
61: message_properties.expiration := 600;
62: enqueue_options.visibility := DBMS_AQ.IMMEDIATE;
63: message := SYSTEM.ieo_icsm_msg_type(p_node_id,request_id,p_xml_data);
64:
65: dbms_aq.enqueue
66: (

Line 65: dbms_aq.enqueue

61: message_properties.expiration := 600;
62: enqueue_options.visibility := DBMS_AQ.IMMEDIATE;
63: message := SYSTEM.ieo_icsm_msg_type(p_node_id,request_id,p_xml_data);
64:
65: dbms_aq.enqueue
66: (
67: queue_name => IEO_QUEUE.queue_name_1,
68: enqueue_options => enqueue_options,
69: message_properties => message_properties,

Line 146: enqueue_options dbms_aq.enqueue_options_t;

142: )
143: IS
144: l_api_name CONSTANT VARCHAR2(30) := 'ENQUEUE_RESPONSE';
145: l_api_version CONSTANT NUMBER := 1.0;
146: enqueue_options dbms_aq.enqueue_options_t;
147: message_properties dbms_aq.message_properties_t;
148: message_handle RAW(16);
149: message SYSTEM.ieo_icsm_msg_type;
150: xml_data_null EXCEPTION;

Line 147: message_properties dbms_aq.message_properties_t;

143: IS
144: l_api_name CONSTANT VARCHAR2(30) := 'ENQUEUE_RESPONSE';
145: l_api_version CONSTANT NUMBER := 1.0;
146: enqueue_options dbms_aq.enqueue_options_t;
147: message_properties dbms_aq.message_properties_t;
148: message_handle RAW(16);
149: message SYSTEM.ieo_icsm_msg_type;
150: xml_data_null EXCEPTION;
151: BEGIN

Line 183: enqueue_options.visibility := DBMS_AQ.IMMEDIATE;

179: END IF;
180:
181: message_properties.correlation := p_request_id;
182: message_properties.expiration := 600;
183: enqueue_options.visibility := DBMS_AQ.IMMEDIATE;
184: message := SYSTEM.ieo_icsm_msg_type(p_node_id,p_request_id,p_xml_data);
185:
186: dbms_aq.enqueue
187: (

Line 186: dbms_aq.enqueue

182: message_properties.expiration := 600;
183: enqueue_options.visibility := DBMS_AQ.IMMEDIATE;
184: message := SYSTEM.ieo_icsm_msg_type(p_node_id,p_request_id,p_xml_data);
185:
186: dbms_aq.enqueue
187: (
188: queue_name => IEO_QUEUE.queue_name_2,
189: enqueue_options => enqueue_options,
190: message_properties => message_properties,

Line 267: dequeue_options dbms_aq.dequeue_options_t;

263: )
264: IS
265: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_REQUEST';
266: l_api_version CONSTANT NUMBER := 1.0;
267: dequeue_options dbms_aq.dequeue_options_t;
268: message_properties dbms_aq.message_properties_t;
269: message_handle RAW(16);
270: message SYSTEM.ieo_icsm_msg_type;
271: no_messages exception;

Line 268: message_properties dbms_aq.message_properties_t;

264: IS
265: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_REQUEST';
266: l_api_version CONSTANT NUMBER := 1.0;
267: dequeue_options dbms_aq.dequeue_options_t;
268: message_properties dbms_aq.message_properties_t;
269: message_handle RAW(16);
270: message SYSTEM.ieo_icsm_msg_type;
271: no_messages exception;
272: pragma exception_init (no_messages, -25228);

Line 301: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;

297: -- API body
298:
299: dequeue_options.correlation := p_node_id;
300: dequeue_options.wait := p_wait ;
301: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
302: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
303:
304: dbms_aq.dequeue
305: (

Line 302: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;

298:
299: dequeue_options.correlation := p_node_id;
300: dequeue_options.wait := p_wait ;
301: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
302: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
303:
304: dbms_aq.dequeue
305: (
306: queue_name => IEO_QUEUE.queue_name_1,

Line 304: dbms_aq.dequeue

300: dequeue_options.wait := p_wait ;
301: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
302: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
303:
304: dbms_aq.dequeue
305: (
306: queue_name => IEO_QUEUE.queue_name_1,
307: dequeue_options => dequeue_options,
308: message_properties => message_properties,

Line 372: dequeue_options dbms_aq.dequeue_options_t;

368: )
369: IS
370: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_RESPONSE';
371: l_api_version CONSTANT NUMBER := 1.0;
372: dequeue_options dbms_aq.dequeue_options_t;
373: message_properties dbms_aq.message_properties_t;
374: message_handle RAW(16);
375: message SYSTEM.ieo_icsm_msg_type;
376: no_messages exception;

Line 373: message_properties dbms_aq.message_properties_t;

369: IS
370: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_RESPONSE';
371: l_api_version CONSTANT NUMBER := 1.0;
372: dequeue_options dbms_aq.dequeue_options_t;
373: message_properties dbms_aq.message_properties_t;
374: message_handle RAW(16);
375: message SYSTEM.ieo_icsm_msg_type;
376: no_messages exception;
377: pragma exception_init (no_messages, -25228);

Line 408: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;

404: --DBMS_OUTPUT.put_line('before dequeuing in dequeue response');
405:
406: dequeue_options.correlation := p_request_id;
407: dequeue_options.wait := p_wait ;
408: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
409: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
410:
411: dbms_aq.dequeue
412: (

Line 409: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;

405:
406: dequeue_options.correlation := p_request_id;
407: dequeue_options.wait := p_wait ;
408: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
409: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
410:
411: dbms_aq.dequeue
412: (
413: queue_name => IEO_QUEUE.queue_name_2,

Line 411: dbms_aq.dequeue

407: dequeue_options.wait := p_wait ;
408: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
409: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
410:
411: dbms_aq.dequeue
412: (
413: queue_name => IEO_QUEUE.queue_name_2,
414: dequeue_options => dequeue_options,
415: message_properties => message_properties,