eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.FND_CP_GSM_IPC dependencies on DBMS_AQ

Line 50: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',

46: pragma AUTONOMOUS_TRANSACTION;
47:
48: Begin
49: if cpid is not null then
50: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',
51: subscriber => sys.aq$_agent('FNDCPGSMIPC_Cartridge_'||to_char(cpid),
52: NULL, NULL));
53:
54: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',

Line 54: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',

50: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',
51: subscriber => sys.aq$_agent('FNDCPGSMIPC_Cartridge_'||to_char(cpid),
52: NULL, NULL));
53:
54: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',
55: subscriber => sys.aq$_agent('FNDCPGSMIPC_Service_'||to_char(cpid),
56: NULL, NULL));
57: else
58: sql_stmt := 'declare ';

Line 67: sql_stmt := sql_stmt || 'DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name => ''';

63:
64: sql_stmt := sql_stmt || ' begin ';
65: sql_stmt := sql_stmt || ' for c1rec in c1 loop ';
66:
67: sql_stmt := sql_stmt || 'DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name => ''';
68: sql_stmt := sql_stmt || Q_Schema || '.FND_CP_GSM_IPC_AQ'', ';
69: sql_stmt := sql_stmt || 'subscriber=>sys.aq$_agent(c1rec.name,NULL,NULL));';
70:
71: sql_stmt := sql_stmt || ' end loop; ';

Line 97: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;

93: procedure Init_Cartridge is
94:
95: Not_Done Boolean;
96: PAYLOAD system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
97: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
98: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
99: msgid raw(16);
100:
101: pragma AUTONOMOUS_TRANSACTION;

Line 98: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;

94:
95: Not_Done Boolean;
96: PAYLOAD system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
97: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
98: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
99: msgid raw(16);
100:
101: pragma AUTONOMOUS_TRANSACTION;
102:

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

102:
103: Begin
104: /* we should clear expired messages out of exception queue */
105: dq_opts.consumer_name := NULL;
106: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
107: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
108: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
109: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
110: dq_opts.MSGID := NULL;

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

103: Begin
104: /* we should clear expired messages out of exception queue */
105: dq_opts.consumer_name := NULL;
106: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
107: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
108: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
109: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
110: dq_opts.MSGID := NULL;
111:

Line 108: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;

104: /* we should clear expired messages out of exception queue */
105: dq_opts.consumer_name := NULL;
106: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
107: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
108: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
109: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
110: dq_opts.MSGID := NULL;
111:
112: Not_Done := TRUE;

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

105: dq_opts.consumer_name := NULL;
106: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
107: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
108: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
109: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
110: dq_opts.MSGID := NULL;
111:
112: Not_Done := TRUE;
113:

Line 116: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.AQ$_FND_CP_GSM_IPC_AQTBL_E',

112: Not_Done := TRUE;
113:
114: while Not_Done LOOP
115: begin
116: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.AQ$_FND_CP_GSM_IPC_AQTBL_E',
117: DEQUEUE_OPTIONS => dq_opts,
118: MESSAGE_PROPERTIES => msg_props,
119: PAYLOAD => payload,
120: MSGID => msgid);

Line 163: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',

159:
160: pragma AUTONOMOUS_TRANSACTION;
161:
162: begin
163: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',
164: subscriber => sys.aq$_agent('FNDCPGSMIPC_Cartridge_'||to_char(cpid),
165: NULL, NULL));
166:
167: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',

Line 167: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',

163: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',
164: subscriber => sys.aq$_agent('FNDCPGSMIPC_Cartridge_'||to_char(cpid),
165: NULL, NULL));
166:
167: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema||'.FND_CP_GSM_IPC_AQ',
168: subscriber => sys.aq$_agent('FNDCPGSMIPC_Service_'||to_char(cpid),
169: NULL, NULL));
170:
171: Send_Message(cpid,'Initialize',Params,Debug_Level);

Line 198: enq_opts DBMS_AQ.enqueue_options_t;

194: Parameters in Varchar2,
195: Debug_Level in Varchar2) is
196:
197:
198: enq_opts DBMS_AQ.enqueue_options_t;
199: msg_props DBMS_AQ.message_properties_t;
200: msg_id raw(16);
201: msg system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
202: sessionid number;

Line 199: msg_props DBMS_AQ.message_properties_t;

195: Debug_Level in Varchar2) is
196:
197:
198: enq_opts DBMS_AQ.enqueue_options_t;
199: msg_props DBMS_AQ.message_properties_t;
200: msg_id raw(16);
201: msg system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
202: sessionid number;
203:

Line 210: enq_opts.visibility := DBMS_AQ.ON_COMMIT;

206: begin
207: msg := system.FND_CP_GSM_IPQ_AQ_PAYLOAD(
208: Handle,Message,Parameters,Debug_Level);
209:
210: enq_opts.visibility := DBMS_AQ.ON_COMMIT;
211: enq_opts.sequence_deviation := NULL;
212: msg_props.delay := DBMS_AQ.NO_DELAY;
213: msg_props.expiration := 365 * 24 * 3600; -- One Year
214: msg_props.recipient_list(1) := sys.aq$_agent(

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

208: Handle,Message,Parameters,Debug_Level);
209:
210: enq_opts.visibility := DBMS_AQ.ON_COMMIT;
211: enq_opts.sequence_deviation := NULL;
212: msg_props.delay := DBMS_AQ.NO_DELAY;
213: msg_props.expiration := 365 * 24 * 3600; -- One Year
214: msg_props.recipient_list(1) := sys.aq$_agent(
215: 'FNDCPGSMIPC_Service_'||to_char(Handle),NULL, NULL);
216: msg_props.sender_id := sys.aq$_agent(

Line 219: DBMS_AQ.Enqueue( queue_name => Q_Schema||'.FND_CP_GSM_IPC_AQ',

215: 'FNDCPGSMIPC_Service_'||to_char(Handle),NULL, NULL);
216: msg_props.sender_id := sys.aq$_agent(
217: 'FNDCPGSMIPC_Cartridge_'||to_char(Handle), NULL, NULL);
218:
219: DBMS_AQ.Enqueue( queue_name => Q_Schema||'.FND_CP_GSM_IPC_AQ',
220: enqueue_options => enq_opts,
221: message_properties => msg_props,
222: Payload => msg,
223: msgid => msg_id);

Line 262: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;

258: Status_Name Varchar2(30);
259: Status_code Varchar2(1);
260: More_Flag Varchar2(1);
261: PAYLOAD system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
262: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
263: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
264: msgid raw(16);
265: last_msg raw(16);
266:

Line 263: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;

259: Status_code Varchar2(1);
260: More_Flag Varchar2(1);
261: PAYLOAD system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
262: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
263: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
264: msgid raw(16);
265: last_msg raw(16);
266:
267: pragma AUTONOMOUS_TRANSACTION;

Line 275: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;

271:
272: while (Not_Done) LOOP -- Clear off excess messages
273:
274: dq_opts.consumer_name := 'FNDCPGSMIPC_Cartridge_'||to_char(Handle);
275: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
276: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
277: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
278: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
279: dq_opts.MSGID := NULL;

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

272: while (Not_Done) LOOP -- Clear off excess messages
273:
274: dq_opts.consumer_name := 'FNDCPGSMIPC_Cartridge_'||to_char(Handle);
275: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
276: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
277: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
278: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
279: dq_opts.MSGID := NULL;
280:

Line 277: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;

273:
274: dq_opts.consumer_name := 'FNDCPGSMIPC_Cartridge_'||to_char(Handle);
275: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
276: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
277: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
278: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
279: dq_opts.MSGID := NULL;
280:
281: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

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

274: dq_opts.consumer_name := 'FNDCPGSMIPC_Cartridge_'||to_char(Handle);
275: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
276: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
277: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
278: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
279: dq_opts.MSGID := NULL;
280:
281: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
282: DEQUEUE_OPTIONS => dq_opts,

Line 281: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

277: dq_opts.VISIBILITY := DBMS_AQ.ON_COMMIT;
278: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
279: dq_opts.MSGID := NULL;
280:
281: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
282: DEQUEUE_OPTIONS => dq_opts,
283: MESSAGE_PROPERTIES => msg_props,
284: PAYLOAD => payload,
285: MSGID => msgid);

Line 290: dq_opts.NAVIGATION := DBMS_AQ.NEXT_MESSAGE;

286:
287: last_msg := msgid;
288: Status_Name := PAYLOAD.Message;
289:
290: dq_opts.NAVIGATION := DBMS_AQ.NEXT_MESSAGE;
291:
292: begin
293: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
294: DEQUEUE_OPTIONS => dq_opts,

Line 293: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

289:
290: dq_opts.NAVIGATION := DBMS_AQ.NEXT_MESSAGE;
291:
292: begin
293: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
294: DEQUEUE_OPTIONS => dq_opts,
295: MESSAGE_PROPERTIES => msg_props,
296: PAYLOAD => payload,
297: MSGID => msgid);

Line 308: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE_NODATA;

304: Not_Done := FALSE;
305: else -- Kill the first message
306: dq_opts.CORRELATION := Null;
307: dq_opts.MSGID := last_msg;
308: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE_NODATA;
309:
310: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
311: DEQUEUE_OPTIONS => dq_opts,
312: MESSAGE_PROPERTIES => msg_props,

Line 310: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

306: dq_opts.CORRELATION := Null;
307: dq_opts.MSGID := last_msg;
308: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE_NODATA;
309:
310: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
311: DEQUEUE_OPTIONS => dq_opts,
312: MESSAGE_PROPERTIES => msg_props,
313: PAYLOAD => payload,
314: MSGID => msgid);

Line 400: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;

396: etrace varchar2(4) := Null;
397: diag_level char := Null;
398: sql_stmt VARCHAR2(200) := null;
399: PAYLOAD system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
400: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
401: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
402: msgid raw(16);
403:
404: pragma AUTONOMOUS_TRANSACTION;

Line 401: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;

397: diag_level char := Null;
398: sql_stmt VARCHAR2(200) := null;
399: PAYLOAD system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
400: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
401: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
402: msgid raw(16);
403:
404: pragma AUTONOMOUS_TRANSACTION;
405:

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

406: begin
407: Update_Status ( Handle, 'Running');
408:
409: dq_opts.consumer_name := 'FNDCPGSMIPC_Service_'|| to_char(Handle);
410: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
411: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
412: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
413: dq_opts.WAIT := DBMS_AQ.FOREVER;
414: dq_opts.MSGID := NULL;

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

407: Update_Status ( Handle, 'Running');
408:
409: dq_opts.consumer_name := 'FNDCPGSMIPC_Service_'|| to_char(Handle);
410: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
411: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
412: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
413: dq_opts.WAIT := DBMS_AQ.FOREVER;
414: dq_opts.MSGID := NULL;
415:

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

408:
409: dq_opts.consumer_name := 'FNDCPGSMIPC_Service_'|| to_char(Handle);
410: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
411: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
412: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
413: dq_opts.WAIT := DBMS_AQ.FOREVER;
414: dq_opts.MSGID := NULL;
415:
416: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

Line 413: dq_opts.WAIT := DBMS_AQ.FOREVER;

409: dq_opts.consumer_name := 'FNDCPGSMIPC_Service_'|| to_char(Handle);
410: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
411: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
412: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
413: dq_opts.WAIT := DBMS_AQ.FOREVER;
414: dq_opts.MSGID := NULL;
415:
416: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
417: DEQUEUE_OPTIONS => dq_opts,

Line 416: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

412: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
413: dq_opts.WAIT := DBMS_AQ.FOREVER;
414: dq_opts.MSGID := NULL;
415:
416: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
417: DEQUEUE_OPTIONS => dq_opts,
418: MESSAGE_PROPERTIES => msg_props,
419: PAYLOAD => payload,
420: MSGID => msgid);

Line 531: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;

527: Blocking_Sleep_Time in number default 30) is
528:
529: Not_Done boolean;
530: payload system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
531: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
532: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
533: msgid raw(16);
534:
535:

Line 532: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;

528:
529: Not_Done boolean;
530: payload system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
531: dq_opts DBMS_AQ.DEQUEUE_OPTIONS_T;
532: msg_props DBMS_AQ.MESSAGE_PROPERTIES_T;
533: msgid raw(16);
534:
535:
536: pragma AUTONOMOUS_TRANSACTION;

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

540:
541: Not_Done := TRUE;
542:
543: if (Consume_Flag = 'Y') then
544: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
545: else
546: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
547: end if;
548:

Line 546: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;

542:
543: if (Consume_Flag = 'Y') then
544: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;
545: else
546: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
547: end if;
548:
549: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
550: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;

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

545: else
546: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
547: end if;
548:
549: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
550: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
551:
552: if (Message_Wait_Timeout is null) then
553: dq_opts.WAIT := DBMS_AQ.NO_WAIT;

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

546: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
547: end if;
548:
549: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
550: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
551:
552: if (Message_Wait_Timeout is null) then
553: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
554: else

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

549: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
550: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
551:
552: if (Message_Wait_Timeout is null) then
553: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
554: else
555: dq_opts.WAIT := Message_Wait_Timeout;
556: end if;
557:

Line 563: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

559: dq_opts.consumer_name := 'FNDCPGSMIPC_Service_'||to_char(Handle);
560:
561: while (Not_Done) LOOP
562: begin
563: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
564: DEQUEUE_OPTIONS => dq_opts,
565: MESSAGE_PROPERTIES => msg_props,
566: PAYLOAD => payload,
567: MSGID => msgid);

Line 592: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;

588: END LOOP;
589:
590: /* set more flag */
591:
592: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
593: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
594: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
595: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
596:

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

589:
590: /* set more flag */
591:
592: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
593: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
594: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
595: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
596:
597: begin

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

590: /* set more flag */
591:
592: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
593: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
594: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
595: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
596:
597: begin
598: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

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

591:
592: dq_opts.DEQUEUE_MODE := DBMS_AQ.BROWSE;
593: dq_opts.NAVIGATION := DBMS_AQ.FIRST_MESSAGE;
594: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
595: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
596:
597: begin
598: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
599: DEQUEUE_OPTIONS => dq_opts,

Line 598: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',

594: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
595: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
596:
597: begin
598: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
599: DEQUEUE_OPTIONS => dq_opts,
600: MESSAGE_PROPERTIES => msg_props,
601: PAYLOAD => payload,
602: MSGID => msgid);

Line 716: msg_props dbms_aq.message_properties_t;

712: /* No longer used */
713: Procedure obsolete_Update_Status ( Handle in Number,
714: Status in Varchar2) is
715:
716: msg_props dbms_aq.message_properties_t;
717: enq_opts dbms_aq.enqueue_options_t;
718: msg system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
719: msg_id raw(16);
720:

Line 717: enq_opts dbms_aq.enqueue_options_t;

713: Procedure obsolete_Update_Status ( Handle in Number,
714: Status in Varchar2) is
715:
716: msg_props dbms_aq.message_properties_t;
717: enq_opts dbms_aq.enqueue_options_t;
718: msg system.FND_CP_GSM_IPQ_AQ_PAYLOAD;
719: msg_id raw(16);
720:
721: pragma AUTONOMOUS_TRANSACTION;

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

722:
723: Begin
724: msg := system.FND_CP_GSM_IPQ_AQ_PAYLOAD(Handle, Status, NULL, NULL);
725:
726: enq_opts.visibility := DBMS_AQ.IMMEDIATE;
727: enq_opts.sequence_deviation := NULL;
728:
729: msg_props.delay := DBMS_AQ.NO_DELAY;
730: msg_props.expiration := 365 * 24 * 3600; -- One Year

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

725:
726: enq_opts.visibility := DBMS_AQ.IMMEDIATE;
727: enq_opts.sequence_deviation := NULL;
728:
729: msg_props.delay := DBMS_AQ.NO_DELAY;
730: msg_props.expiration := 365 * 24 * 3600; -- One Year
731: msg_props.recipient_list(1) :=sys.aq$_agent(
732: 'FNDCPGSMIPC_Cartridge_'||to_char(Handle),NULL,NULL);
733: msg_props.sender_id := sys.aq$_agent(

Line 736: DBMS_AQ.Enqueue( queue_name => Q_Schema||'.FND_CP_GSM_IPC_AQ',

732: 'FNDCPGSMIPC_Cartridge_'||to_char(Handle),NULL,NULL);
733: msg_props.sender_id := sys.aq$_agent(
734: 'FNDCPGSMIPC_Service_'||to_char(Handle), NULL, NULL);
735:
736: DBMS_AQ.Enqueue( queue_name => Q_Schema||'.FND_CP_GSM_IPC_AQ',
737: enqueue_options => enq_opts,
738: message_properties => msg_props,
739: Payload => msg,
740: msgid => msg_id);