APPS.XDP_AQ_UTILITIES dependencies on DBMS_AQADM

Line 99: DBMS_AQADM.CREATE_QUEUE_TABLE(

95: p_return_code := 0;
96:
97: /* Create queue table */
98: BEGIN
99: DBMS_AQADM.CREATE_QUEUE_TABLE(
100: queue_table => p_queue_table,
101: queue_payload_type => p_payload,
102: sort_list => 'priority,enq_time',
103: storage_clause => lv_storage);

Line 114: DBMS_AQADM.CREATE_QUEUE(

110: End;
111:
112: -- Create the queue
113: BEGIN
114: DBMS_AQADM.CREATE_QUEUE(
115: queue_name => p_queue_name,
116: queue_table => p_queue_table,
117: max_retries => p_max_retries);
118: Exception

Line 127: DBMS_AQADM.START_QUEUE(p_queue_name);

123: end if;
124: End;
125:
126: -- Enable enqueue and dequeue operations for SimpleQ.
127: DBMS_AQADM.START_QUEUE(p_queue_name);
128:
129: -- Create an exception queue
130: IF p_expq_name IS NOT NULL THEN
131: BEGIN

Line 132: DBMS_AQADM.CREATE_QUEUE(

128:
129: -- Create an exception queue
130: IF p_expq_name IS NOT NULL THEN
131: BEGIN
132: DBMS_AQADM.CREATE_QUEUE(
133: queue_name => p_expq_name,
134: queue_table => p_queue_table,
135: queue_type => DBMS_AQADM.EXCEPTION_QUEUE,
136: comment => 'Exception queue for '||p_queue_name);

Line 135: queue_type => DBMS_AQADM.EXCEPTION_QUEUE,

131: BEGIN
132: DBMS_AQADM.CREATE_QUEUE(
133: queue_name => p_expq_name,
134: queue_table => p_queue_table,
135: queue_type => DBMS_AQADM.EXCEPTION_QUEUE,
136: comment => 'Exception queue for '||p_queue_name);
137: Exception
138: when others then
139: /* ignore queue exists error*/

Line 146: DBMS_AQADM.START_QUEUE(p_expq_name,FALSE,TRUE);

142: end if;
143: End;
144:
145: /* Enable dequeue operations for exceptionQ.*/
146: DBMS_AQADM.START_QUEUE(p_expq_name,FALSE,TRUE);
147: END IF;
148:
149:
150: EXCEPTION

Line 176: DBMS_AQADM.STOP_QUEUE(queue_name => lv_aq_rec.internal_q_name);

172: BEGIN
173:
174: p_return_code := 0;
175: FOR lv_aq_rec IN lc_aq LOOP
176: DBMS_AQADM.STOP_QUEUE(queue_name => lv_aq_rec.internal_q_name);
177: END LOOP;
178:
179: EXCEPTION
180: WHEN OTHERS THEN

Line 203: DBMS_AQADM.DROP_QUEUE_TABLE(

199: BEGIN
200:
201: p_return_code := 0;
202: FOR lv_aq_rec IN lc_aq LOOP
203: DBMS_AQADM.DROP_QUEUE_TABLE(
204: queue_table => lv_aq_rec.queue_table_name,
205: force => TRUE);
206:
207: END LOOP;