APPS.FND_CP_GSM_IPC dependencies on AQ$_AGENT

Line 51: subscriber => sys.aq$_agent('FNDCPGSMIPC_Cartridge_'||to_char(cpid),

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',
55: subscriber => sys.aq$_agent('FNDCPGSMIPC_Service_'||to_char(cpid),

Line 55: subscriber => sys.aq$_agent('FNDCPGSMIPC_Service_'||to_char(cpid),

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 ';
59:

Line 69: sql_stmt := sql_stmt || 'subscriber=>sys.aq$_agent(c1rec.name,NULL,NULL));';

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;';
73:

Line 164: subscriber => sys.aq$_agent('FNDCPGSMIPC_Cartridge_'||to_char(cpid),

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',
168: subscriber => sys.aq$_agent('FNDCPGSMIPC_Service_'||to_char(cpid),

Line 168: subscriber => sys.aq$_agent('FNDCPGSMIPC_Service_'||to_char(cpid),

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);
172: Update_Status (cpid, 'Uninitialized');

Line 214: msg_props.recipient_list(1) := sys.aq$_agent(

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(
217: 'FNDCPGSMIPC_Cartridge_'||to_char(Handle), NULL, NULL);
218:

Line 216: msg_props.sender_id := sys.aq$_agent(

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(
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,

Line 771: msg_props.recipient_list(1) :=sys.aq$_agent(

767: enq_opts.sequence_deviation := NULL;
768:
769: msg_props.delay := DBMS_AQ.NO_DELAY;
770: msg_props.expiration := 365 * 24 * 3600; -- One Year
771: msg_props.recipient_list(1) :=sys.aq$_agent(
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:

Line 773: msg_props.sender_id := sys.aq$_agent(

769: msg_props.delay := DBMS_AQ.NO_DELAY;
770: msg_props.expiration := 365 * 24 * 3600; -- One Year
771: msg_props.recipient_list(1) :=sys.aq$_agent(
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,