APPS.CCT_MQD_PUB dependencies on DBMS_AQ

Line 182: dequeue_options dbms_aq.dequeue_options_t;

178: l_classification varchar2(1024);
179: x_err_num NUMBER;
180: x_err_msg VARCHAR2(256);
181: l_kvp cct_keyvalue_varr := cct_keyvalue_varr();
182: dequeue_options dbms_aq.dequeue_options_t;
183: message_properties dbms_aq.message_properties_t;
184: message_handle RAW(16);
185: message SYSTEM.cct_qde_response;
186: no_messages exception;

Line 183: message_properties dbms_aq.message_properties_t;

179: x_err_num NUMBER;
180: x_err_msg VARCHAR2(256);
181: l_kvp cct_keyvalue_varr := cct_keyvalue_varr();
182: dequeue_options dbms_aq.dequeue_options_t;
183: message_properties dbms_aq.message_properties_t;
184: message_handle RAW(16);
185: message SYSTEM.cct_qde_response;
186: no_messages exception;
187: pragma exception_init (no_messages, -25228);

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

216:
217: begin
218: dequeue_options.correlation := p_agent_id;
219: dequeue_options.wait := 0 ;
220: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
221: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
222: dbms_aq.dequeue(
223: queue_name => CCT_QDE_QUEUE.queue_name,
224: dequeue_options => dequeue_options,

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

217: begin
218: dequeue_options.correlation := p_agent_id;
219: dequeue_options.wait := 0 ;
220: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
221: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
222: dbms_aq.dequeue(
223: queue_name => CCT_QDE_QUEUE.queue_name,
224: dequeue_options => dequeue_options,
225: message_properties => message_properties,

Line 222: dbms_aq.dequeue(

218: dequeue_options.correlation := p_agent_id;
219: dequeue_options.wait := 0 ;
220: dequeue_options.visibility := DBMS_AQ.IMMEDIATE;
221: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
222: dbms_aq.dequeue(
223: queue_name => CCT_QDE_QUEUE.queue_name,
224: dequeue_options => dequeue_options,
225: message_properties => message_properties,
226: payload => message,