APPS.WF_HA_MIGRATION dependencies on AQ$_AGENT

Line 229: myagent sys.aq$_agent;

225: --
226: PROCEDURE FixSubscriptions(WF_Schema in varchar2 default 'APPLSYS',
227: Clone_DBLink in varchar2) is
228:
229: myagent sys.aq$_agent;
230: address_string varchar2(1024) := 'WF_REPLAY_IN';
231: kount number;
232: WF_Schema2 varchar2(1024);
233:

Line 252: myagent := sys.aq$_agent('MyDummyAgent',NULL, NULL);

248: WF_Schema2 := WF_Schema;
249: end if;
250:
251: /* insert dummy subscriber to make sure view works */
252: myagent := sys.aq$_agent('MyDummyAgent',NULL, NULL);
253:
254: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>WF_Schema2 || '.WF_REPLAY_OUT',
255: subscriber=>myagent);
256:

Line 269: sql_stmt := sql_stmt || 'subscriber=>sys.aq$_agent(';

265: sql_stmt := sql_stmt || ' for c1rec in c1 loop ';
266:
267: sql_stmt := sql_stmt || 'DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name => ''';
268: sql_stmt := sql_stmt || WF_Schema2 || '.WF_REPLAY_OUT'', ';
269: sql_stmt := sql_stmt || 'subscriber=>sys.aq$_agent(';
270: sql_stmt := sql_stmt || 'c1rec.NAME, c1rec.ADDRESS, c1rec.PROTOCOL));';
271:
272: /* turn off propogation for old subscriber if active */
273: sql_stmt := sql_stmt || ' begin ';

Line 326: myagent := sys.aq$_agent('WF_REPLAY_IN', address_string, 0);

322: if (Clone_DBLink is not null) then
323: address_string := address_string || '@' || Clone_DBLink;
324: end if;
325:
326: myagent := sys.aq$_agent('WF_REPLAY_IN', address_string, 0);
327: dbms_aqadm.add_subscriber(queue_name =>WF_Schema2||'.WF_REPLAY_OUT',
328: subscriber=>myagent);
329:
330: commit;