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 FND_CP_GSM_IPC

Line 1: PACKAGE BODY fnd_cp_gsm_ipc AS

1: PACKAGE BODY fnd_cp_gsm_ipc AS
2: /* $Header: AFCPSMIB.pls 120.5.12020000.2 2012/12/10 22:37:28 ckclark ship $ */
3:
4:
5:

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 61: sql_stmt := sql_stmt || ' from '||Q_Schema||'.aq$FND_CP_GSM_IPC_AQTBL_S ';

57: else
58: sql_stmt := 'declare ';
59:
60: sql_stmt := sql_stmt || 'CURSOR C1 is select NAME name ';
61: sql_stmt := sql_stmt || ' from '||Q_Schema||'.aq$FND_CP_GSM_IPC_AQTBL_S ';
62: sql_stmt := sql_stmt || ' where QUEUE=''FND_CP_GSM_IPC_AQ'';';
63:
64: sql_stmt := sql_stmt || ' begin ';
65: sql_stmt := sql_stmt || ' for c1rec in c1 loop ';

Line 62: sql_stmt := sql_stmt || ' where QUEUE=''FND_CP_GSM_IPC_AQ'';';

58: sql_stmt := 'declare ';
59:
60: sql_stmt := sql_stmt || 'CURSOR C1 is select NAME name ';
61: sql_stmt := sql_stmt || ' from '||Q_Schema||'.aq$FND_CP_GSM_IPC_AQTBL_S ';
62: sql_stmt := sql_stmt || ' where QUEUE=''FND_CP_GSM_IPC_AQ'';';
63:
64: sql_stmt := sql_stmt || ' begin ';
65: sql_stmt := sql_stmt || ' for c1rec in c1 loop ';
66:

Line 68: sql_stmt := sql_stmt || Q_Schema || '.FND_CP_GSM_IPC_AQ'', ';

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; ';
72: sql_stmt := sql_stmt || ' end;';

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 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 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 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 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 409: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',

405:
406: begin
407: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
408: fnd_log.string(FND_LOG.LEVEL_STATEMENT,
409: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',
410: 'Enter procedure - Handle = '||to_char(Handle));
411: end if;
412: Update_Status ( Handle, 'Running');
413:

Line 416: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',

412: Update_Status ( Handle, 'Running');
413:
414: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
415: fnd_log.string(FND_LOG.LEVEL_STATEMENT,
416: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',
417: 'Handle ' ||to_char(Handle)||': status updated to running');
418: end if;
419: dq_opts.consumer_name := 'FNDCPGSMIPC_Service_'|| to_char(Handle);
420: dq_opts.DEQUEUE_MODE := DBMS_AQ.REMOVE;

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

422: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
423: dq_opts.WAIT := DBMS_AQ.FOREVER;
424: dq_opts.MSGID := NULL;
425:
426: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
427: DEQUEUE_OPTIONS => dq_opts,
428: MESSAGE_PROPERTIES => msg_props,
429: PAYLOAD => payload,
430: MSGID => msgid);

Line 445: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',

441: and rownum <= 1; /* Probably not necessary */
442:
443: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
444: fnd_log.string(FND_LOG.LEVEL_STATEMENT,
445: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',
446: 'Handle ' ||to_char(Handle)||': pid='||to_char(p_id)||', spid='||osp_id||', audsid='||to_char(s_id));
447: end if;
448:
449: /* 5867853- Make sure the fcp row for services, like that of FNDSM

Line 468: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',

464: AND PROCESS_STATUS_CODE = 'A';
465:
466: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
467: fnd_log.string(FND_LOG.LEVEL_STATEMENT,
468: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',
469: 'Handle ' ||to_char(Handle)||': sqlnet_string='|| sqlnet_str);
470: end if;
471:
472: /* 5867853- Update DB_INSTANCE and SQLNET_STRING for services */

Line 486: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',

482: where CONCURRENT_PROCESS_ID = Handle;
483:
484: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
485: fnd_log.string(FND_LOG.LEVEL_STATEMENT,
486: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',
487: 'Handle ' ||to_char(Handle)||': fnd_concurrent_processes updated');
488: end if;
489:
490: select Concurrent_Queue_Name, Resource_Consumer_Group, Diagnostic_level

Line 499: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',

495: And P.Concurrent_Process_Id = Handle;
496:
497: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
498: fnd_log.string(FND_LOG.LEVEL_STATEMENT,
499: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',
500: 'Handle ' ||to_char(Handle)||': Concurrent_Queue_Name='||service_name||', Resource_Consumer_Group='||que_rcg||', Diagnostic_level='||diag_level);
501: end if;
502:
503: -- Until we add explicit support for TRACE ON/OFF

Line 530: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',

526: end;
527:
528: if( FND_LOG.LEVEL_STATEMENT >= FND_LOG.G_CURRENT_RUNTIME_LEVEL ) then
529: fnd_log.string(FND_LOG.LEVEL_STATEMENT,
530: 'fnd.plsql.FND_CP_GSM_IPC.Init_Service',
531: 'Handle ' ||to_char(Handle)||': Work completed successfully, commiting');
532: end if;
533:
534: commit;

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

599: dq_opts.consumer_name := 'FNDCPGSMIPC_Service_'||to_char(Handle);
600:
601: while (Not_Done) LOOP
602: begin
603: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
604: DEQUEUE_OPTIONS => dq_opts,
605: MESSAGE_PROPERTIES => msg_props,
606: PAYLOAD => payload,
607: MSGID => msgid);

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

634: dq_opts.VISIBILITY := DBMS_AQ.IMMEDIATE;
635: dq_opts.WAIT := DBMS_AQ.NO_WAIT;
636:
637: begin
638: DBMS_AQ.DEQUEUE(QUEUE_NAME=>Q_Schema||'.FND_CP_GSM_IPC_AQ',
639: DEQUEUE_OPTIONS => dq_opts,
640: MESSAGE_PROPERTIES => msg_props,
641: PAYLOAD => payload,
642: MSGID => msgid);

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

772: 'FNDCPGSMIPC_Cartridge_'||to_char(Handle),NULL,NULL);
773: msg_props.sender_id := sys.aq$_agent(
774: 'FNDCPGSMIPC_Service_'||to_char(Handle), NULL, NULL);
775:
776: DBMS_AQ.Enqueue( queue_name => Q_Schema||'.FND_CP_GSM_IPC_AQ',
777: enqueue_options => enq_opts,
778: message_properties => msg_props,
779: Payload => msg,
780: msgid => msg_id);

Line 796: END fnd_cp_gsm_ipc;

792: Function Status_Running return varchar2 is begin return('Running'); end;
793: Function Status_Stopped return varchar2 is begin return('Stopped'); end;
794: Function Status_Suspended return varchar2 is begin return('Suspended'); end;
795:
796: END fnd_cp_gsm_ipc;