APPS.WF_QUEUE dependencies on DBMS_AQADM

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

2443:
2444: /*
2445: ** Stop the queue
2446: */
2447: dbms_aqadm.stop_queue(queue_name => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||
2448: p_protocol||'_'||substr(p_inbound_outbound, 1, 1)||'_'||
2449: to_char(ii)||'_QUEUE');
2450: /*
2451: ** Delete the Queues

Line 2453: dbms_aqadm.drop_queue(

2449: to_char(ii)||'_QUEUE');
2450: /*
2451: ** Delete the Queues
2452: */
2453: dbms_aqadm.drop_queue(
2454: queue_name => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||
2455: substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_QUEUE');
2456:
2457: /*

Line 2460: dbms_aqadm.drop_queue_table (

2456:
2457: /*
2458: ** Delete the Queue Table
2459: */
2460: dbms_aqadm.drop_queue_table (
2461: queue_table => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_TABLE');
2462:
2463: end loop;
2464:

Line 2635: dbms_aqadm.create_queue_table (

2631:
2632: /*
2633: ** Create New Queue Table
2634: */
2635: dbms_aqadm.create_queue_table (
2636: queue_table => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_TABLE',
2637: queue_payload_type => 'SYSTEM.WF_MESSAGE_PAYLOAD_T',
2638: storage_clause => 'storage (initial 1m next 1m pctincrease 0 )',
2639: sort_list => 'PRIORITY,ENQ_TIME',

Line 2646: dbms_aqadm.create_queue(

2642:
2643: /*
2644: ** Create New Queues
2645: */
2646: dbms_aqadm.create_queue(
2647: queue_name => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||
2648: substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_QUEUE',
2649: queue_table => wf_core.translate('WF_SCHEMA')||'.'||'WF_'||p_protocol||'_'||
2650: substr(p_inbound_outbound, 1, 1)||'_'||to_char(ii)||'_TABLE',

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

2655:
2656: /*
2657: ** Start the queue
2658: */
2659: dbms_aqadm.start_queue(queue_name => wf_core.translate('WF_SCHEMA')||'.'||
2660: 'WF_'||p_protocol||'_'||
2661: substr(p_inbound_outbound, 1, 1)|| '_'||to_char(ii)||'_QUEUE');
2662:
2663: end loop;

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

2865: raise;
2866: end;
2867:
2868: if l_exception_queue <> '' and l_dequeue_enabled = 'NO' then
2869: dbms_aqadm.start_queue(queue_name => l_exception_queue,
2870: enqueue => FALSE,
2871: dequeue => TRUE);
2872: end if;
2873: return l_exception_queue;

Line 2892: DBMS_AQADM.Add_Subscriber(

2888: lagent sys.aq$_agent;
2889: begin
2890: lagent := sys.aq$_agent(name,'',0);
2891:
2892: DBMS_AQADM.Add_Subscriber(
2893: queue_name=>queuename,
2894: subscriber=>lagent,
2895: rule=>'CORRID like '''||name||'%'''
2896: );

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

2930: OPEN q_disabled (schema, queue_name);
2931: LOOP
2932: FETCH q_disabled into l_qname;
2933: EXIT WHEN q_disabled%NOTFOUND;
2934: DBMS_AQADM.START_QUEUE(wf_queue.deferred_queue_name);
2935: END LOOP;
2936: CLOSE q_disabled;
2937:
2938: --Enable inbound queue

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

2940: OPEN q_disabled (schema, queue_name);
2941: LOOP
2942: FETCH q_disabled into l_qname;
2943: EXIT WHEN q_disabled%NOTFOUND;
2944: DBMS_AQADM.START_QUEUE(wf_queue.inbound_queue_name);
2945: END LOOP;
2946: CLOSE q_disabled;
2947: exception
2948: when others then