DBA Data[Home] [Help]

APPS.AMV_AQ_UTILITY_PVT dependencies on AMV_QUEUE

Line 72: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,

68: -- End of comments
69: --
70: PROCEDURE Add_Queue
71: (
72: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
73: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,
74: p_payload_obj_type IN VARCHAR2 := 'SYSTEM.AMV_AQ_MSG_OBJECT_TYPE'
75: );
76: --

Line 73: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,

69: --
70: PROCEDURE Add_Queue
71: (
72: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
73: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,
74: p_payload_obj_type IN VARCHAR2 := 'SYSTEM.AMV_AQ_MSG_OBJECT_TYPE'
75: );
76: --
77: --------------------------------------------------------------------------------

Line 101: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,

97: -- Note :
98: -- End of comments
99: PROCEDURE Delete_Queue
100: (
101: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
102: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name
103: );
104: --
105: --------------------------------------------------------------------------------

Line 102: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name

98: -- End of comments
99: PROCEDURE Delete_Queue
100: (
101: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
102: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name
103: );
104: --
105: --------------------------------------------------------------------------------
106: -- Start of comments

Line 160: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,

156: -- They are supported to be handled by the higher level callers.
157: --------------------------------------------------------------------------------
158: PROCEDURE Add_Queue
159: (
160: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
161: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,
162: p_payload_obj_type IN VARCHAR2 := 'SYSTEM.AMV_AQ_MSG_OBJECT_TYPE'
163: ) IS
164: --

Line 161: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,

157: --------------------------------------------------------------------------------
158: PROCEDURE Add_Queue
159: (
160: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
161: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,
162: p_payload_obj_type IN VARCHAR2 := 'SYSTEM.AMV_AQ_MSG_OBJECT_TYPE'
163: ) IS
164: --
165: l_comment varchar2(2000) := '';

Line 173: IF p_queue_table_name = AMV_QUEUE.queue_table_name THEN

169: OPEN Get_AQ_table_csr (p_queue_table_name);
170: Fetch Get_AQ_table_csr INTO l_temp_str;
171: IF (Get_AQ_table_csr%NOTFOUND) THEN
172: CLOSE Get_AQ_table_csr;
173: IF p_queue_table_name = AMV_QUEUE.queue_table_name THEN
174: l_comment :=
175: 'This AQ queue table is used by MES matching engine AQ queue.';
176: END IF;
177: --Create priority queue table.

Line 193: IF p_queue_name = AMV_QUEUE.queue_name THEN

189: OPEN Get_AQ_queue_csr (p_queue_name, p_queue_table_name);
190: Fetch Get_AQ_queue_csr INTO l_temp_str;
191: IF (Get_AQ_queue_csr%NOTFOUND) THEN
192: CLOSE Get_AQ_queue_csr;
193: IF p_queue_name = AMV_QUEUE.queue_name THEN
194: l_comment :=
195: 'This AQ queue is used by MES matching engine AQ queue.';
196: END IF;
197: --Create the AQ queue.

Line 214: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,

210: END Add_Queue;
211: --------------------------------------------------------------------------------
212: PROCEDURE Delete_Queue
213: (
214: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
215: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name
216: ) IS
217: l_temp_str varchar2(200);
218: BEGIN

Line 215: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name

211: --------------------------------------------------------------------------------
212: PROCEDURE Delete_Queue
213: (
214: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
215: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name
216: ) IS
217: l_temp_str varchar2(200);
218: BEGIN
219: -- Make sure the AQ queue does exist.

Line 266: queue_name => AMV_QUEUE.queue_name,

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,
269: payload => p_message_obj,
270: msgid => l_message_enq_id

Line 291: queue_name => AMV_QUEUE.queue_name,

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,
294: payload => x_message_obj,
295: msgid => l_message_handle

Line 310: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,

306: x_return_status OUT NOCOPY VARCHAR2,
307: x_msg_count OUT NOCOPY NUMBER,
308: x_msg_data OUT NOCOPY VARCHAR2,
309: p_check_login_user IN VARCHAR2 := FND_API.G_TRUE,
310: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
311: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,
312: p_payload_obj_type IN VARCHAR2 := 'SYSTEM.AMV_AQ_MSG_OBJECT_TYPE'
313: ) IS
314: l_api_name CONSTANT VARCHAR2(30) := 'Add_Queue';

Line 311: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,

307: x_msg_count OUT NOCOPY NUMBER,
308: x_msg_data OUT NOCOPY VARCHAR2,
309: p_check_login_user IN VARCHAR2 := FND_API.G_TRUE,
310: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
311: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name,
312: p_payload_obj_type IN VARCHAR2 := 'SYSTEM.AMV_AQ_MSG_OBJECT_TYPE'
313: ) IS
314: l_api_name CONSTANT VARCHAR2(30) := 'Add_Queue';
315: l_api_version CONSTANT NUMBER := 1.0;

Line 431: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,

427: x_return_status OUT NOCOPY VARCHAR2,
428: x_msg_count OUT NOCOPY NUMBER,
429: x_msg_data OUT NOCOPY VARCHAR2,
430: p_check_login_user IN VARCHAR2 := FND_API.G_TRUE,
431: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
432: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name
433: ) IS
434: l_api_name CONSTANT VARCHAR2(30) := 'Delete_Queue';
435: l_api_version CONSTANT NUMBER := 1.0;

Line 432: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name

428: x_msg_count OUT NOCOPY NUMBER,
429: x_msg_data OUT NOCOPY VARCHAR2,
430: p_check_login_user IN VARCHAR2 := FND_API.G_TRUE,
431: p_queue_table_name IN VARCHAR2 := AMV_QUEUE.queue_table_name,
432: p_queue_name IN VARCHAR2 := AMV_QUEUE.queue_name
433: ) IS
434: l_api_name CONSTANT VARCHAR2(30) := 'Delete_Queue';
435: l_api_version CONSTANT NUMBER := 1.0;
436: l_resource_id NUMBER := -1;