DBA Data[Home] [Help]

APPS.WF_BES_CLEANUP dependencies on DBMS_AQADM

Line 262: dbms_aqadm.remove_subscriber(

258: purge_jms_queue(p_queue_name => p_owner || '.' || p_queue_name,
259: p_consumer_name => p_subscriber_name);
260: -- remove the subscriber from the queue
261:
262: dbms_aqadm.remove_subscriber(
263: queue_name => p_owner || '.' || p_queue_name,
264: subscriber => sys.aq$_agent(p_subscriber_name, null, null));
265:
266: -- mark the subscriber removed

Line 382: l_subscribers dbms_aqadm.aq$_subscriber_list_t;

378: l_ping_time date;
379: l_ping_number number;
380: l_remove_failed_count number;
381: l_remove_status varchar2(30);
382: l_subscribers dbms_aqadm.aq$_subscriber_list_t;
383: i integer;
384: begin
385: -- get the last ping time
386:

Line 452: l_subscribers := dbms_aqadm.queue_subscribers(l_owner || '.' || l_queue_name);

448:
449: -- After remove the subscribers, remove all the messages that got moved to exception queue
450: purge_jms_queue(p_queue_name => l_owner || '.AQ$_WF_CONTROL_E');
451: -- ping the current subscribers
452: l_subscribers := dbms_aqadm.queue_subscribers(l_owner || '.' || l_queue_name);
453:
454: if(l_subscribers.count() > 0) then
455: -- a subscriber exists
456: