DBA Data[Home] [Help]

APPS.AMV_AQ_UTILITY_PVT dependencies on DBMS_AQ

Line 178: dbms_aqadm.create_queue_table (

174: l_comment :=
175: 'This AQ queue table is used by MES matching engine AQ queue.';
176: END IF;
177: --Create priority queue table.
178: dbms_aqadm.create_queue_table (
179: queue_table => p_queue_table_name,
180: comment => l_comment,
181: sort_list => 'PRIORITY,ENQ_TIME',
182: queue_payload_type => p_payload_obj_type);

Line 198: dbms_aqadm.create_queue (

194: l_comment :=
195: 'This AQ queue is used by MES matching engine AQ queue.';
196: END IF;
197: --Create the AQ queue.
198: dbms_aqadm.create_queue (
199: queue_name => p_queue_name,
200: queue_table => p_queue_table_name,
201: --compatible => '8.1', -- Comment out: current version not latest.
202: comment => l_comment

Line 209: dbms_aqadm.start_queue ( queue_name=>p_queue_name);

205: CLOSE Get_AQ_queue_csr;
206: -- The queue is already there. No need to re-create it.
207: END IF;
208: --Start the AQ queue just created.
209: dbms_aqadm.start_queue ( queue_name=>p_queue_name);
210: END Add_Queue;
211: --------------------------------------------------------------------------------
212: PROCEDURE Delete_Queue
213: (

Line 224: dbms_aqadm.stop_queue(p_queue_name);

220: OPEN Get_AQ_queue_csr (p_queue_name, p_queue_table_name);
221: Fetch Get_AQ_queue_csr INTO l_temp_str;
222: IF (Get_AQ_queue_csr%FOUND) THEN
223: CLOSE Get_AQ_queue_csr;
224: dbms_aqadm.stop_queue(p_queue_name);
225: dbms_aqadm.drop_queue(p_queue_name);
226: ELSE
227: CLOSE Get_AQ_queue_csr;
228: -- The queue does not exist. No need to drop it.

Line 225: dbms_aqadm.drop_queue(p_queue_name);

221: Fetch Get_AQ_queue_csr INTO l_temp_str;
222: IF (Get_AQ_queue_csr%FOUND) THEN
223: CLOSE Get_AQ_queue_csr;
224: dbms_aqadm.stop_queue(p_queue_name);
225: dbms_aqadm.drop_queue(p_queue_name);
226: ELSE
227: CLOSE Get_AQ_queue_csr;
228: -- The queue does not exist. No need to drop it.
229: END IF;

Line 235: dbms_aqadm.drop_queue_table(p_queue_table_name);

231: OPEN Get_AQ_table_csr (p_queue_table_name);
232: Fetch Get_AQ_table_csr INTO l_temp_str;
233: IF (Get_AQ_table_csr%FOUND) THEN
234: CLOSE Get_AQ_table_csr;
235: dbms_aqadm.drop_queue_table(p_queue_table_name);
236: ELSE
237: CLOSE Get_AQ_table_csr;
238: -- The table does not exist. No need to drop it.
239: END IF;

Line 242: -- dbms_aqadm.drop_queue_table

238: -- The table does not exist. No need to drop it.
239: END IF;
240: --POST CODE PHASE:
241: --The code below will drop all queues (in the table) and the queue table.
242: -- dbms_aqadm.drop_queue_table
243: -- (
244: -- queue_table => p_queue_table_name
245: -- force => TRUE
246: -- );

Line 256: l_enqueue_options dbms_aq.enqueue_options_t;

252: (
253: p_message_obj IN SYSTEM.AMV_AQ_MSG_OBJECT_TYPE
254: ) IS
255: --
256: l_enqueue_options dbms_aq.enqueue_options_t;
257: l_message_properties dbms_aq.message_properties_t;
258: l_message_enq_id RAW(16);
259: --
260: BEGIN

Line 257: l_message_properties dbms_aq.message_properties_t;

253: p_message_obj IN SYSTEM.AMV_AQ_MSG_OBJECT_TYPE
254: ) IS
255: --
256: l_enqueue_options dbms_aq.enqueue_options_t;
257: l_message_properties dbms_aq.message_properties_t;
258: l_message_enq_id RAW(16);
259: --
260: BEGIN
261: --l_message_properties.priority := 10;

Line 264: dbms_aq.enqueue

260: BEGIN
261: --l_message_properties.priority := 10;
262: --We do use priority for special case.
263: l_message_properties.priority := p_message_obj.priority;
264: dbms_aq.enqueue
265: (
266: queue_name => AMV_QUEUE.queue_name,
267: enqueue_options => l_enqueue_options,
268: message_properties => l_message_properties,

Line 280: l_dequeue_options dbms_aq.dequeue_options_t;

276: (
277: p_delete_flag IN VARCHAR2 := FND_API.G_TRUE,
278: x_message_obj OUT NOCOPY SYSTEM.AMV_AQ_MSG_OBJECT_TYPE
279: ) IS
280: l_dequeue_options dbms_aq.dequeue_options_t;
281: l_message_properties dbms_aq.message_properties_t;
282: l_message_handle RAW(16);
283: BEGIN
284: IF (p_delete_flag = FND_API.G_FALSE) THEN

Line 281: l_message_properties dbms_aq.message_properties_t;

277: p_delete_flag IN VARCHAR2 := FND_API.G_TRUE,
278: x_message_obj OUT NOCOPY SYSTEM.AMV_AQ_MSG_OBJECT_TYPE
279: ) IS
280: l_dequeue_options dbms_aq.dequeue_options_t;
281: l_message_properties dbms_aq.message_properties_t;
282: l_message_handle RAW(16);
283: BEGIN
284: IF (p_delete_flag = FND_API.G_FALSE) THEN
285: l_dequeue_options.dequeue_mode := DBMS_AQ.BROWSE;

Line 285: l_dequeue_options.dequeue_mode := DBMS_AQ.BROWSE;

281: l_message_properties dbms_aq.message_properties_t;
282: l_message_handle RAW(16);
283: BEGIN
284: IF (p_delete_flag = FND_API.G_FALSE) THEN
285: l_dequeue_options.dequeue_mode := DBMS_AQ.BROWSE;
286: END IF;
287: -- Set the waiting option for the Dequeue to No_WAIT
288: l_dequeue_options.wait := DBMS_AQ.NO_WAIT;
289: dbms_aq.dequeue

Line 288: l_dequeue_options.wait := DBMS_AQ.NO_WAIT;

284: IF (p_delete_flag = FND_API.G_FALSE) THEN
285: l_dequeue_options.dequeue_mode := DBMS_AQ.BROWSE;
286: END IF;
287: -- Set the waiting option for the Dequeue to No_WAIT
288: l_dequeue_options.wait := DBMS_AQ.NO_WAIT;
289: dbms_aq.dequeue
290: (
291: queue_name => AMV_QUEUE.queue_name,
292: dequeue_options => l_dequeue_options,

Line 289: dbms_aq.dequeue

285: l_dequeue_options.dequeue_mode := DBMS_AQ.BROWSE;
286: END IF;
287: -- Set the waiting option for the Dequeue to No_WAIT
288: l_dequeue_options.wait := DBMS_AQ.NO_WAIT;
289: dbms_aq.dequeue
290: (
291: queue_name => AMV_QUEUE.queue_name,
292: dequeue_options => l_dequeue_options,
293: message_properties => l_message_properties,