APPS.WF_QUEUE dependencies on DBMS_AQADM

Line 2427: dbms_aqadm.stop_queue(queue_name => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||

2423:
2424: /*
2425: ** Stop the queue
2426: */
2427: dbms_aqadm.stop_queue(queue_name => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||
2428: p_protocol||'_'||substr(p_inbound_outbound, 1, 1)||'_'||
2429: to_char(ii)||'_QUEUE');
2430: /*
2431: ** Delete the Queues

Line 2433: dbms_aqadm.drop_queue(

2429: to_char(ii)||'_QUEUE');
2430: /*
2431: ** Delete the Queues
2432: */
2433: dbms_aqadm.drop_queue(
2434: queue_name => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||
2435: substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_QUEUE');
2436:
2437: /*

Line 2440: dbms_aqadm.drop_queue_table (

2436:
2437: /*
2438: ** Delete the Queue Table
2439: */
2440: dbms_aqadm.drop_queue_table (
2441: queue_table => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_TABLE');
2442:
2443: end loop;
2444:

Line 2615: dbms_aqadm.create_queue_table (

2611:
2612: /*
2613: ** Create New Queue Table
2614: */
2615: dbms_aqadm.create_queue_table (
2616: queue_table => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_TABLE',
2617: queue_payload_type => 'SYSTEM.WF_MESSAGE_PAYLOAD_T',
2618: storage_clause => 'storage (initial 1m next 1m pctincrease 0 )',
2619: sort_list => 'PRIORITY,ENQ_TIME',

Line 2626: dbms_aqadm.create_queue(

2622:
2623: /*
2624: ** Create New Queues
2625: */
2626: dbms_aqadm.create_queue(
2627: queue_name => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||
2628: substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_QUEUE',
2629: queue_table => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||
2630: substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_TABLE',

Line 2639: dbms_aqadm.start_queue(queue_name => wf_core.translate('WF_SCHEMA')||'.'||

2635:
2636: /*
2637: ** Start the queue
2638: */
2639: dbms_aqadm.start_queue(queue_name => wf_core.translate('WF_SCHEMA')||'.'||
2640: 'WF_'||p_protocol||'_'||
2641: substr(p_inbound_outbound, 1, 1)|| '_'||to_char(ii)||'_QUEUE');
2642:
2643: end loop;

Line 2849: dbms_aqadm.start_queue(queue_name => l_exception_queue,

2845: raise;
2846: end;
2847:
2848: if l_exception_queue <> '' and l_dequeue_enabled = 'NO' then
2849: dbms_aqadm.start_queue(queue_name => l_exception_queue,
2850: enqueue => FALSE,
2851: dequeue => TRUE);
2852: end if;
2853: return l_exception_queue;

Line 2872: DBMS_AQADM.Add_Subscriber(

2868: lagent sys.aq$_agent;
2869: begin
2870: lagent := sys.aq$_agent(name,'',0);
2871:
2872: DBMS_AQADM.Add_Subscriber(
2873: queue_name=>queuename,
2874: subscriber=>lagent,
2875: rule=>'CORRID like '''||name||'%'''
2876: );

Line 2914: DBMS_AQADM.START_QUEUE(wf_queue.deferred_queue_name);

2910: OPEN q_disabled (schema, queue_name);
2911: LOOP
2912: FETCH q_disabled into l_qname;
2913: EXIT WHEN q_disabled%NOTFOUND;
2914: DBMS_AQADM.START_QUEUE(wf_queue.deferred_queue_name);
2915: END LOOP;
2916: CLOSE q_disabled;
2917:
2918: --Enable inbound queue

Line 2924: DBMS_AQADM.START_QUEUE(wf_queue.inbound_queue_name);

2920: OPEN q_disabled (schema, queue_name);
2921: LOOP
2922: FETCH q_disabled into l_qname;
2923: EXIT WHEN q_disabled%NOTFOUND;
2924: DBMS_AQADM.START_QUEUE(wf_queue.inbound_queue_name);
2925: END LOOP;
2926: CLOSE q_disabled;
2927: exception
2928: when others then