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;
27: BEGIN
28: -- Standard Start of API savepoint
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: (
67: queue_name => IEO_QUEUE.queue_name_1,
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
152: -- Standard Start of API savepoint
153: SAVEPOINT ENQUEUE_RESPONSE_PUB;
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: (
188: queue_name => IEO_QUEUE.queue_name_2,
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);
273: BEGIN
274: -- Standard Start of API savepoint
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);
378: BEGIN
379: -- Standard Start of API savepoint