APPS.FND_CP_TMSRV_QUEUE dependencies on DBMS_AQ

Line 36: P_ENQ_OPTS DBMS_AQ.enqueue_options_t;

32: Q_Name varchar2(64) := null;
33: RetQ_Name varchar2(64) := null;
34: P_SENDER_ID varchar2(30) := null;
35: P_SENDER_AGENT sys.aq$_agent;
36: P_ENQ_OPTS DBMS_AQ.enqueue_options_t;
37: P_DEQ_OPTS DBMS_AQ.dequeue_options_t;
38: P_CORRELATION_ID varchar2(32);
39:
40:

Line 37: P_DEQ_OPTS DBMS_AQ.dequeue_options_t;

33: RetQ_Name varchar2(64) := null;
34: P_SENDER_ID varchar2(30) := null;
35: P_SENDER_AGENT sys.aq$_agent;
36: P_ENQ_OPTS DBMS_AQ.enqueue_options_t;
37: P_DEQ_OPTS DBMS_AQ.dequeue_options_t;
38: P_CORRELATION_ID varchar2(32);
39:
40:
41: --

Line 61: P_ENQ_OPTS.visibility := DBMS_AQ.IMMEDIATE;

57:
58: P_SENDER_ID := TMPREFIX || pid;
59: P_SENDER_AGENT := sys.aq$_agent(P_SENDER_ID, NULL, NULL);
60:
61: P_ENQ_OPTS.visibility := DBMS_AQ.IMMEDIATE;
62: P_ENQ_OPTS.sequence_deviation := NULL;
63:
64: select PROCESSOR_APPLICATION_ID || '.' || CONCURRENT_PROCESSOR_ID
65: into P_CORRELATION_ID

Line 69: P_DEQ_OPTS.dequeue_mode := DBMS_AQ.REMOVE;

65: into P_CORRELATION_ID
66: from fnd_concurrent_queues
67: where concurrent_queue_id = qid;
68:
69: P_DEQ_OPTS.dequeue_mode := DBMS_AQ.REMOVE;
70: P_DEQ_OPTS.navigation := DBMS_AQ.FIRST_MESSAGE;
71: P_DEQ_OPTS.visibility := DBMS_AQ.IMMEDIATE;
72: P_DEQ_OPTS.consumer_name := TMQID;
73: P_DEQ_OPTS.correlation := P_CORRELATION_ID;

Line 70: P_DEQ_OPTS.navigation := DBMS_AQ.FIRST_MESSAGE;

66: from fnd_concurrent_queues
67: where concurrent_queue_id = qid;
68:
69: P_DEQ_OPTS.dequeue_mode := DBMS_AQ.REMOVE;
70: P_DEQ_OPTS.navigation := DBMS_AQ.FIRST_MESSAGE;
71: P_DEQ_OPTS.visibility := DBMS_AQ.IMMEDIATE;
72: P_DEQ_OPTS.consumer_name := TMQID;
73: P_DEQ_OPTS.correlation := P_CORRELATION_ID;
74:

Line 71: P_DEQ_OPTS.visibility := DBMS_AQ.IMMEDIATE;

67: where concurrent_queue_id = qid;
68:
69: P_DEQ_OPTS.dequeue_mode := DBMS_AQ.REMOVE;
70: P_DEQ_OPTS.navigation := DBMS_AQ.FIRST_MESSAGE;
71: P_DEQ_OPTS.visibility := DBMS_AQ.IMMEDIATE;
72: P_DEQ_OPTS.consumer_name := TMQID;
73: P_DEQ_OPTS.correlation := P_CORRELATION_ID;
74:
75: r := fnd_installation.get_app_info('FND', status, industry, schema);

Line 138: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;

134: arg_19 in out nocopy varchar2,
135: arg_20 in out nocopy varchar2) is
136:
137: payload system.FND_CP_TM_AQ_PAYLOAD;
138: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
139: msgid raw(16);
140: queue_timeout exception;
141: enable_trace varchar2(255);
142: sql_stmt varchar2(255);

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

154: P_DEQ_OPTS.WAIT := timeout;
155:
156: begin
157:
158: DBMS_AQ.DEQUEUE(QUEUE_NAME => Q_Name,
159: DEQUEUE_OPTIONS => P_DEQ_OPTS,
160: MESSAGE_PROPERTIES => msg_props,
161: PAYLOAD => payload,
162: MSGID => msgid);

Line 280: msg_props DBMS_AQ.message_properties_t;

276: reqid in number,
277: outcome in varchar2,
278: message in varchar2) is
279:
280: msg_props DBMS_AQ.message_properties_t;
281: msg_id raw(16);
282: msg system.FND_CP_TM_AQ_PAYLOAD;
283:
284: begin

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

333: FNDCP_TMSRV.P_RETURN_VALS(19),
334: FNDCP_TMSRV.P_RETURN_VALS(20)
335: );
336:
337: msg_props.delay := DBMS_AQ.NO_DELAY;
338:
339: msg_props.sender_id := P_SENDER_AGENT;
340:
341: msg_props.recipient_list(0) := sys.aq$_agent(TMPREFIX || reqid, NULL, NULL);

Line 347: DBMS_AQ.Enqueue( queue_name => RetQ_Name,

343: -- don't let the message stay on the queue forever, but don't make the queue monitor
344: -- work too hard...
345: msg_props.expiration := 600;
346:
347: DBMS_AQ.Enqueue( queue_name => RetQ_Name,
348: enqueue_options => P_ENQ_OPTS,
349: message_properties => msg_props,
350: Payload => msg,
351: msgid => msg_id);