APPS.FND_CP_OPP_IPC dependencies on AQ$_AGENT

Line 47: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL));

43: pragma AUTONOMOUS_TRANSACTION;
44:
45: Begin
46: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,
47: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL));
48:
49:
50: commit;
51:

Line 76: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL),

72: pragma AUTONOMOUS_TRANSACTION;
73:
74: Begin
75: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,
76: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL),
77: rule => 'tab.user_data.message_group = ''' || groupid || '''');
78:
79:
80: commit;

Line 100: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL));

96: pragma AUTONOMOUS_TRANSACTION;
97:
98: Begin
99: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name =>Q_Schema || '.' || QUEUE_NAME,
100: subscriber => sys.aq$_agent(OPPPREFIX || subscriber, NULL, NULL));
101:
102:
103: commit;
104:

Line 193: subscriber => sys.aq$_agent(subname, NULL, NULL));

189: fetch c1 into subname;
190: exit when c1%NOTFOUND;
191:
192: DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name => Q_Schema || '.' || QUEUE_NAME,
193: subscriber => sys.aq$_agent(subname, NULL, NULL));
194: end loop;
195: close c1;
196:
197: end;

Line 266: msg_props.sender_id := sys.aq$_agent(OPPPREFIX || sender, NULL, NULL);

262: enq_opts.sequence_deviation := NULL;
263: msg_props.delay := DBMS_AQ.NO_DELAY;
264: msg_props.expiration := 365 * 24 * 3600; -- One Year
265:
266: msg_props.sender_id := sys.aq$_agent(OPPPREFIX || sender, NULL, NULL);
267:
268: if correlation is not null then
269: msg_props.correlation := correlation;
270: end if;

Line 275: msg_props.recipient_list(i) := sys.aq$_agent(OPPPREFIX || recipients(i), NULL, NULL);

271:
272: if recipients is not null then
273: for i in 1 .. recipients.COUNT
274: loop
275: msg_props.recipient_list(i) := sys.aq$_agent(OPPPREFIX || recipients(i), NULL, NULL);
276: end loop;
277: end if;
278:
279: DBMS_AQ.Enqueue( queue_name => Q_Schema || '.' || QUEUE_NAME,