APPS.CCT_AQ_PUB dependencies on DBMS_AQ

Line 51: enqueue_options dbms_aq.enqueue_options_t;

47: )
48: IS
49: l_api_name CONSTANT VARCHAR2(30) := 'ENQUEUE_ITEM';
50: l_api_version CONSTANT NUMBER := 1.0;
51: enqueue_options dbms_aq.enqueue_options_t;
52: message_properties dbms_aq.message_properties_t;
53: message_handle RAW(16);
54: message SYSTEM.cct_ibmedia_type;
55: final_xml_data1 VARCHAR2(2048);

Line 52: message_properties dbms_aq.message_properties_t;

48: IS
49: l_api_name CONSTANT VARCHAR2(30) := 'ENQUEUE_ITEM';
50: l_api_version CONSTANT NUMBER := 1.0;
51: enqueue_options dbms_aq.enqueue_options_t;
52: message_properties dbms_aq.message_properties_t;
53: message_handle RAW(16);
54: message SYSTEM.cct_ibmedia_type;
55: final_xml_data1 VARCHAR2(2048);
56: server_group_name_null EXCEPTION;

Line 116: dbms_aq.enqueue(queue_name => CCT_QUEUE.queue_name,

112: message := SYSTEM.cct_ibmedia_type(SYSDATE,p_server_group_id,p_app_id,final_xml_data1);
113:
114: --dbms_output.put_line ('ENQUEUE_ITEM: MessageCreated');
115:
116: dbms_aq.enqueue(queue_name => CCT_QUEUE.queue_name,
117: enqueue_options => enqueue_options,
118: message_properties => message_properties,
119: payload => message,
120: msgid => message_handle);

Line 261: dequeue_options dbms_aq.dequeue_options_t;

257: )
258: IS
259: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_ITEM';
260: l_api_version CONSTANT NUMBER := 1.0;
261: dequeue_options dbms_aq.dequeue_options_t;
262: message_properties dbms_aq.message_properties_t;
263: message_handle RAW(16);
264: message SYSTEM.cct_ibmedia_type;
265: server_group_id_null EXCEPTION;

Line 262: message_properties dbms_aq.message_properties_t;

258: IS
259: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_ITEM';
260: l_api_version CONSTANT NUMBER := 1.0;
261: dequeue_options dbms_aq.dequeue_options_t;
262: message_properties dbms_aq.message_properties_t;
263: message_handle RAW(16);
264: message SYSTEM.cct_ibmedia_type;
265: server_group_id_null EXCEPTION;
266: no_messages exception;

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

289: -- API body
290:
291: dequeue_options.correlation := p_server_group_id;
292: dequeue_options.wait := 15 ;
293: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
294: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
295:
296:
297: --dbms_output.put_line('DEQUEUE_ITEM: dequeue correlation ' || p_server_group_id);

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

290:
291: dequeue_options.correlation := p_server_group_id;
292: dequeue_options.wait := 15 ;
293: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
294: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
295:
296:
297: --dbms_output.put_line('DEQUEUE_ITEM: dequeue correlation ' || p_server_group_id);
298:

Line 299: dbms_aq.dequeue(

295:
296:
297: --dbms_output.put_line('DEQUEUE_ITEM: dequeue correlation ' || p_server_group_id);
298:
299: dbms_aq.dequeue(
300: queue_name => CCT_QUEUE.queue_name,
301: dequeue_options => dequeue_options,
302: message_properties => message_properties,
303: payload => message,