APPS.WF_HA_MIGRATION dependencies on DBMS_AQADM

Line 254: DBMS_AQADM.ADD_SUBSCRIBER(queue_name =>WF_Schema2 || '.WF_REPLAY_OUT',

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:
257: /* Remove all subscribers */
258: sql_stmt := 'declare ';

Line 267: sql_stmt := sql_stmt || 'DBMS_AQADM.REMOVE_SUBSCRIBER(queue_name => ''';

263:
264: sql_stmt := sql_stmt || ' begin ';
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:

Line 275: sql_stmt := sql_stmt || ' dbms_aqadm.unschedule_propagation (';

271:
272: /* turn off propogation for old subscriber if active */
273: sql_stmt := sql_stmt || ' begin ';
274: sql_stmt := sql_stmt || ' if instr(c1rec.ADDRESS,''@'') > 0 then ';
275: sql_stmt := sql_stmt || ' dbms_aqadm.unschedule_propagation (';
276: sql_stmt := sql_stmt || ' queue_name => ''' ||
277: WF_Schema2||'.WF_REPLAY_OUT'', ';
278: sql_stmt := sql_stmt || ' destination => ' ||
279: 'substr(c1rec.ADDRESS, instr(c1rec.ADDRESS,''@'') + 1) ); ';

Line 292: dbms_aqadm.unschedule_propagation (

288: EXECUTE IMMEDIATE sql_stmt ;
289:
290: /* just to be safe turn off local prop */
291: begin
292: dbms_aqadm.unschedule_propagation (
293: queue_name => WF_Schema2||'.WF_REPLAY_OUT',
294: destination =>null
295: );
296: exception

Line 304: dbms_aqadm.unschedule_propagation (

300:
301: /* just to be safe turn off prop to new destination */
302: begin
303: if (Clone_DBLink is not null) then
304: dbms_aqadm.unschedule_propagation (
305: queue_name => WF_Schema2||'.WF_REPLAY_OUT',
306: destination =>Clone_DBLink
307: );
308: end if;

Line 315: dbms_aqadm.schedule_propagation (

311: null;
312: end;
313:
314: /* turn on prop to new clone */
315: dbms_aqadm.schedule_propagation (
316: queue_name => WF_Schema2||'.WF_REPLAY_OUT',
317: destination => 'Clone_DBLink', duration => 60,
318: next_time => 'SYSDATE + 1/24/60/6');
319:

Line 327: dbms_aqadm.add_subscriber(queue_name =>WF_Schema2||'.WF_REPLAY_OUT',

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;
331: end;