DBA Data[Home] [Help]

APPS.JTF_FM_REQUEST_GRP dependencies on DBMS_AQ

Line 138: l_dequeue_options dbms_aq.dequeue_options_t;

134: p_enqueue_name IN VARCHAR2,
135: x_new_msg_handle OUT NOCOPY RAW)
136: IS
137:
138: l_dequeue_options dbms_aq.dequeue_options_t;
139: l_enqueue_options dbms_aq.enqueue_options_t;
140: l_message_properties dbms_aq.message_properties_t;
141: l_message RAW(32767);
142: l_in_msg RAW(16) := p_in_msg;

Line 139: l_enqueue_options dbms_aq.enqueue_options_t;

135: x_new_msg_handle OUT NOCOPY RAW)
136: IS
137:
138: l_dequeue_options dbms_aq.dequeue_options_t;
139: l_enqueue_options dbms_aq.enqueue_options_t;
140: l_message_properties dbms_aq.message_properties_t;
141: l_message RAW(32767);
142: l_in_msg RAW(16) := p_in_msg;
143: l_api_name CONSTANT VARCHAR2(30) := 'SWAP_QUEUES';

Line 140: l_message_properties dbms_aq.message_properties_t;

136: IS
137:
138: l_dequeue_options dbms_aq.dequeue_options_t;
139: l_enqueue_options dbms_aq.enqueue_options_t;
140: l_message_properties dbms_aq.message_properties_t;
141: l_message RAW(32767);
142: l_in_msg RAW(16) := p_in_msg;
143: l_api_name CONSTANT VARCHAR2(30) := 'SWAP_QUEUES';
144: l_full_name CONSTANT VARCHAR2(2000) := G_PKG_NAME || '.' || l_api_name;

Line 151: l_dequeue_options.wait := dbms_aq.no_wait;

147: JTF_FM_UTL_V.PRINT_MESSAGE('BEGIN' || l_full_name, JTF_FM_UTL_V.G_LEVEL_PROCEDURE ,l_full_name);
148:
149: --default the queue values
150:
151: l_dequeue_options.wait := dbms_aq.no_wait;
152: l_dequeue_options.navigation := dbms_aq.first_message;
153: l_dequeue_options.msgid := p_in_msg;
154: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
155:

Line 152: l_dequeue_options.navigation := dbms_aq.first_message;

148:
149: --default the queue values
150:
151: l_dequeue_options.wait := dbms_aq.no_wait;
152: l_dequeue_options.navigation := dbms_aq.first_message;
153: l_dequeue_options.msgid := p_in_msg;
154: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
155:
156:

Line 154: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;

150:
151: l_dequeue_options.wait := dbms_aq.no_wait;
152: l_dequeue_options.navigation := dbms_aq.first_message;
153: l_dequeue_options.msgid := p_in_msg;
154: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
155:
156:
157: dbms_aq.dequeue(queue_name => p_dequeue_name, dequeue_options =>
158: l_dequeue_options, message_properties => l_message_properties,payload => l_message,

Line 157: dbms_aq.dequeue(queue_name => p_dequeue_name, dequeue_options =>

153: l_dequeue_options.msgid := p_in_msg;
154: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
155:
156:
157: dbms_aq.dequeue(queue_name => p_dequeue_name, dequeue_options =>
158: l_dequeue_options, message_properties => l_message_properties,payload => l_message,
159: MSGID => l_in_msg);
160:
161:

Line 163: dbms_aq.enqueue(queue_name => p_enqueue_name, enqueue_options => l_enqueue_options,

159: MSGID => l_in_msg);
160:
161:
162: -- Enqueue the message into the pause queue
163: dbms_aq.enqueue(queue_name => p_enqueue_name, enqueue_options => l_enqueue_options,
164: message_properties => l_message_properties,
165: payload => l_message, msgid => x_new_msg_handle);
166:
167: JTF_FM_UTL_V.PRINT_MESSAGE('END' || l_full_name, JTF_FM_UTL_V.G_LEVEL_PROCEDURE ,l_full_name);

Line 4571: l_enqueue_options dbms_aq.enqueue_options_t;

4567: l_message2 VARCHAR2(32767);
4568: l_request_queue VARCHAR2(100);
4569: l_response_queue VARCHAR2(100);
4570: l_cnt NUMBER := 0;
4571: l_enqueue_options dbms_aq.enqueue_options_t;
4572: l_message_properties dbms_aq.message_properties_t;
4573: l_message_handle RAW(16);
4574: l_mesg RAW(32767);
4575: l_priority NUMBER;

Line 4572: l_message_properties dbms_aq.message_properties_t;

4568: l_request_queue VARCHAR2(100);
4569: l_response_queue VARCHAR2(100);
4570: l_cnt NUMBER := 0;
4571: l_enqueue_options dbms_aq.enqueue_options_t;
4572: l_message_properties dbms_aq.message_properties_t;
4573: l_message_handle RAW(16);
4574: l_mesg RAW(32767);
4575: l_priority NUMBER;
4576: l_server_id NUMBER;

Line 4715: dbms_aq.enqueue(queue_name => l_request_queue,

4711: -- Set the default message properties
4712: l_message_properties.priority := l_priority;
4713: -- Enqueue the request in to the Request queue for the
4714: -- fulfillment Processor
4715: dbms_aq.enqueue(queue_name => l_request_queue,
4716: enqueue_options => l_enqueue_options,
4717: message_properties => l_message_properties,
4718: payload => l_mesg, msgid => l_message_handle);
4719:

Line 4868: l_enqueue_options dbms_aq.enqueue_options_t;

4864: l_message4 VARCHAR2(32767);
4865: l_request_queue VARCHAR2(100);
4866: l_response_queue VARCHAR2(100);
4867: l_cnt NUMBER := 0;
4868: l_enqueue_options dbms_aq.enqueue_options_t;
4869: l_message_properties dbms_aq.message_properties_t;
4870: l_message_handle RAW(16);
4871: l_buffer VARCHAR2(32767);
4872: l_attachment BLOB;

Line 4869: l_message_properties dbms_aq.message_properties_t;

4865: l_request_queue VARCHAR2(100);
4866: l_response_queue VARCHAR2(100);
4867: l_cnt NUMBER := 0;
4868: l_enqueue_options dbms_aq.enqueue_options_t;
4869: l_message_properties dbms_aq.message_properties_t;
4870: l_message_handle RAW(16);
4871: l_buffer VARCHAR2(32767);
4872: l_attachment BLOB;
4873: l_mesg RAW(32767);

Line 5040: dbms_aq.enqueue(queue_name => l_request_queue,

5036:
5037: xmlparser.FREEPARSER(l_parser);
5038:
5039: -- Enqueue the message into the request queue
5040: dbms_aq.enqueue(queue_name => l_request_queue,
5041: enqueue_options => l_enqueue_options,
5042: message_properties => l_message_properties,
5043: payload => UTL_RAW.CAST_TO_RAW(l_message1), msgid => l_message_handle);
5044:

Line 5335: l_enqueue_options dbms_aq.enqueue_options_t;

5331: l_message LONG;
5332: l_request_queue VARCHAR2(100);
5333: l_response_queue VARCHAR2(100);
5334: l_cnt NUMBER := 0;
5335: l_enqueue_options dbms_aq.enqueue_options_t;
5336: l_message_properties dbms_aq.message_properties_t;
5337: l_message_handle RAW(16);
5338: l_buffer LONG;
5339: l_attachment BLOB;

Line 5336: l_message_properties dbms_aq.message_properties_t;

5332: l_request_queue VARCHAR2(100);
5333: l_response_queue VARCHAR2(100);
5334: l_cnt NUMBER := 0;
5335: l_enqueue_options dbms_aq.enqueue_options_t;
5336: l_message_properties dbms_aq.message_properties_t;
5337: l_message_handle RAW(16);
5338: l_buffer LONG;
5339: l_attachment BLOB;
5340: l_mesg RAW(32767);

Line 5655: dbms_aq.enqueue(queue_name => l_request_queue,

5651:
5652:
5653: -- Enqueue the message into the request queue
5654:
5655: dbms_aq.enqueue(queue_name => l_request_queue,
5656: enqueue_options => l_enqueue_options,
5657: message_properties => l_message_properties,
5658: payload => UTL_RAW.CAST_TO_RAW(l_footprint_xml), msgid => l_message_handle);
5659:

Line 6213: l_dequeue_options dbms_aq.dequeue_options_t;

6209: l_Error_Msg VARCHAR2(2000);
6210: --
6211: l_request_queue VARCHAR2(100);
6212: l_response_queue VARCHAR2(100);
6213: l_dequeue_options dbms_aq.dequeue_options_t;
6214: l_message_properties dbms_aq.message_properties_t;
6215: l_message_handle RAW(16);
6216: l_mesg RAW(32767);
6217: l_server_id NUMBER;

Line 6214: l_message_properties dbms_aq.message_properties_t;

6210: --
6211: l_request_queue VARCHAR2(100);
6212: l_response_queue VARCHAR2(100);
6213: l_dequeue_options dbms_aq.dequeue_options_t;
6214: l_message_properties dbms_aq.message_properties_t;
6215: l_message_handle RAW(16);
6216: l_mesg RAW(32767);
6217: l_server_id NUMBER;
6218: l_meaning VARCHAR2(20);

Line 6317: l_dequeue_options.wait := dbms_aq.no_wait;

6313:
6314: RAISE FND_API.G_EXC_ERROR;
6315: END IF;
6316:
6317: l_dequeue_options.wait := dbms_aq.no_wait;
6318: l_dequeue_options.navigation := dbms_aq.first_message;
6319: l_dequeue_options.msgid := l_message_handle;
6320: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
6321:

Line 6318: l_dequeue_options.navigation := dbms_aq.first_message;

6314: RAISE FND_API.G_EXC_ERROR;
6315: END IF;
6316:
6317: l_dequeue_options.wait := dbms_aq.no_wait;
6318: l_dequeue_options.navigation := dbms_aq.first_message;
6319: l_dequeue_options.msgid := l_message_handle;
6320: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
6321:
6322: -- Based on the req type, get the Queue Name

Line 6320: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;

6316:
6317: l_dequeue_options.wait := dbms_aq.no_wait;
6318: l_dequeue_options.navigation := dbms_aq.first_message;
6319: l_dequeue_options.msgid := l_message_handle;
6320: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
6321:
6322: -- Based on the req type, get the Queue Name
6323: -- If it was a Mass req, check JTF_FM_REQUESTS_AQ as the mass req would have
6324: -- been split into several batch requests.

Line 6334: dbms_aq.dequeue(queue_name => l_request_queue, dequeue_options =>

6330: IF l_request_status = 'SUBMITTED' THEN
6331: -- It is still in the mass queue, server has not picked it up
6332: -- So, remove it from there
6333: BEGIN
6334: dbms_aq.dequeue(queue_name => l_request_queue, dequeue_options =>
6335: l_dequeue_options, message_properties => l_message_properties,
6336: payload => l_mesg, msgid => l_message_handle);
6337: EXCEPTION
6338: WHEN OTHERS THEN

Line 6369: dbms_aq.dequeue(queue_name => l_request_queue, dequeue_options =>

6365: l_request_queue := GET_QUEUE_NAME(l_queue_type,l_server_id);
6366: l_dequeue_options.msgid := l_message_handle;
6367: --dbms_output.put_line('Removing from queue' || l_request_queue);
6368: --dbms_output.put_line('message Id is :'|| l_message_handle);
6369: dbms_aq.dequeue(queue_name => l_request_queue, dequeue_options =>
6370: l_dequeue_options, message_properties => l_message_properties,
6371: payload => l_mesg, msgid => l_message_handle);
6372:
6373: --dbms_output.put_line('dequed');

Line 6383: dbms_aq.dequeue(queue_name => l_request_queue, dequeue_options =>

6379: END IF;
6380: ELSE --- Request type is Single or Batch, so req has only one message_id
6381: --dbms_output.put_line('Single or Batch removing from its queue');
6382: BEGIN
6383: dbms_aq.dequeue(queue_name => l_request_queue, dequeue_options =>
6384: l_dequeue_options, message_properties => l_message_properties,
6385: payload => l_mesg, msgid => l_message_handle);
6386: EXCEPTION
6387: WHEN OTHERS THEN

Line 7377: l_enqueue_options dbms_aq.enqueue_options_t;

7373: l_request_status VARCHAR2(30);
7374: l_message_handle RAW(16);
7375: l_message_handle_new RAW(16);
7376: l_meaning VARCHAR2(20);
7377: l_enqueue_options dbms_aq.enqueue_options_t;
7378: l_message_properties dbms_aq.message_properties_t;
7379: l_request_queue VARCHAR2(1000);
7380: l_footprint_xml VARCHAR2(32767);
7381:

Line 7378: l_message_properties dbms_aq.message_properties_t;

7374: l_message_handle RAW(16);
7375: l_message_handle_new RAW(16);
7376: l_meaning VARCHAR2(20);
7377: l_enqueue_options dbms_aq.enqueue_options_t;
7378: l_message_properties dbms_aq.message_properties_t;
7379: l_request_queue VARCHAR2(1000);
7380: l_footprint_xml VARCHAR2(32767);
7381:
7382: --GET THE SERVER ID, message and QueueType

Line 7551: dbms_aq.enqueue(queue_name => l_request_queue,

7547: l_footprint_xml := ' ';
7548:
7549: -- Enqueue the message into the request queue
7550: l_request_queue := GET_QUEUE_NAME('M',l_server_id);
7551: dbms_aq.enqueue(queue_name => l_request_queue,
7552: enqueue_options => l_enqueue_options,
7553: message_properties => l_message_properties,
7554: payload => UTL_RAW.CAST_TO_RAW(l_footprint_xml), msgid => l_message_handle);
7555: