DBA Data[Home] [Help]

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.3.12000000.3 2007/11/02 15:53:45 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 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 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 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 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);

Line 756: END fnd_cp_gsm_ipc;

752: Function Status_Running return varchar2 is begin return('Running'); end;
753: Function Status_Stopped return varchar2 is begin return('Stopped'); end;
754: Function Status_Suspended return varchar2 is begin return('Suspended'); end;
755:
756: END fnd_cp_gsm_ipc;