APPS.FND_TRANSACTION_QUEUE dependencies on DBMS_AQ

Line 196: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;

192: status varchar2(1);
193: industry varchar2(1);
194: retval number;
195: schema varchar2(30);
196: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
197: queue_timeout exception;
198: enq_opts DBMS_AQ.enqueue_options_t;
199: msg_props DBMS_AQ.message_properties_t;
200: msg system.FND_CP_TM_AQ_PAYLOAD;

Line 198: enq_opts DBMS_AQ.enqueue_options_t;

194: retval number;
195: schema varchar2(30);
196: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
197: queue_timeout exception;
198: enq_opts DBMS_AQ.enqueue_options_t;
199: msg_props DBMS_AQ.message_properties_t;
200: msg system.FND_CP_TM_AQ_PAYLOAD;
201: msg_id raw(16);
202: time_left number;

Line 199: msg_props DBMS_AQ.message_properties_t;

195: schema varchar2(30);
196: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
197: queue_timeout exception;
198: enq_opts DBMS_AQ.enqueue_options_t;
199: msg_props DBMS_AQ.message_properties_t;
200: msg system.FND_CP_TM_AQ_PAYLOAD;
201: msg_id raw(16);
202: time_left number;
203: end_time date;

Line 259: enq_opts.visibility := DBMS_AQ.IMMEDIATE;

255: substr(arg_19, 1, argmax),
256: substr(arg_20, 1, argmax)
257: );
258:
259: enq_opts.visibility := DBMS_AQ.IMMEDIATE;
260: enq_opts.sequence_deviation := NULL;
261: msg_props.delay := DBMS_AQ.NO_DELAY;
262:
263: msg_props.sender_id := sys.aq$_agent(TMPREFIX || request_id, NULL, NULL);

Line 261: msg_props.delay := DBMS_AQ.NO_DELAY;

257: );
258:
259: enq_opts.visibility := DBMS_AQ.IMMEDIATE;
260: enq_opts.sequence_deviation := NULL;
261: msg_props.delay := DBMS_AQ.NO_DELAY;
262:
263: msg_props.sender_id := sys.aq$_agent(TMPREFIX || request_id, NULL, NULL);
264:
265: msg_props.recipient_list(0) := sys.aq$_agent(TMQID, NULL, NULL);

Line 271: DBMS_AQ.Enqueue( queue_name => Q_Name,

267: msg_props.correlation := processor_id;
268:
269:
270: -- Queue the transaction message
271: DBMS_AQ.Enqueue( queue_name => Q_Name,
272: enqueue_options => enq_opts,
273: message_properties => msg_props,
274: Payload => msg,
275: msgid => msg_id);

Line 286: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;

282: msg := system.FND_CP_TM_AQ_PAYLOAD(NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,
283: NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,
284: NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL);
285:
286: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
287: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
288: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
289: dq_opts.MSGID := NULL;
290:

Line 287: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;

283: NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,
284: NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL);
285:
286: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
287: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
288: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
289: dq_opts.MSGID := NULL;
290:
291:

Line 288: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;

284: NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL);
285:
286: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
287: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
288: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
289: dq_opts.MSGID := NULL;
290:
291:
292:

Line 313: DBMS_AQ.DEQUEUE(QUEUE_NAME => RetQ_Name,

309:
310: begin
311:
312: -- Listen for the return message
313: DBMS_AQ.DEQUEUE(QUEUE_NAME => RetQ_Name,
314: DEQUEUE_OPTIONS => dq_opts,
315: MESSAGE_PROPERTIES => msg_props,
316: PAYLOAD => msg,
317: MSGID => msg_id);

Line 335: dq_opts.WAIT := DBMS_AQ.NO_WAIT;

331: -- Timed out waiting for return message
332: begin
333: /* remove our message from the queue */
334: dq_opts.MSGID := msg_id;
335: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
336: dq_opts.consumer_name := TMQID;
337: DBMS_AQ.DEQUEUE(QUEUE_NAME => Q_Name,
338: DEQUEUE_OPTIONS => dq_opts,
339: MESSAGE_PROPERTIES => msg_props,

Line 337: DBMS_AQ.DEQUEUE(QUEUE_NAME => Q_Name,

333: /* remove our message from the queue */
334: dq_opts.MSGID := msg_id;
335: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
336: dq_opts.consumer_name := TMQID;
337: DBMS_AQ.DEQUEUE(QUEUE_NAME => Q_Name,
338: DEQUEUE_OPTIONS => dq_opts,
339: MESSAGE_PROPERTIES => msg_props,
340: PAYLOAD => msg,
341: MSGID => msg_id);