APPS.OKC_AQ_PVT dependencies on AQ$_AGENT

Line 628: l_agent_list DBMS_AQ.aq$_agent_list_t;

624: ,p_wait IN INTEGER
625: ,p_sleep IN NUMBER
626: )
627: IS
628: l_agent_list DBMS_AQ.aq$_agent_list_t;
629: l_agent SYS.aq$_agent;
630: l_index integer;
631: l_procedure VARCHAR2(200);
632: l_retval INTEGER;

Line 629: l_agent SYS.aq$_agent;

625: ,p_sleep IN NUMBER
626: )
627: IS
628: l_agent_list DBMS_AQ.aq$_agent_list_t;
629: l_agent SYS.aq$_agent;
630: l_index integer;
631: l_procedure VARCHAR2(200);
632: l_retval INTEGER;
633: e_listen_timeout EXCEPTION;

Line 657: l_agent_list(l_index) := SYS.aq$_agent ( r_subscriber.name

653:
654: -- okc_debug.Log('50: Before subscriber LOOP',2);
655:
656: FOR r_subscriber IN c_subscriber LOOP
657: l_agent_list(l_index) := SYS.aq$_agent ( r_subscriber.name
658: , OKC_AQ_PVT.g_event_queue_name
659: , NULL );
660: l_index := l_index + 1;
661: END LOOP;

Line 719: l_agent_list DBMS_AQ.aq$_agent_list_t;

715: ,p_sleep IN NUMBER
716: )
717:
718: IS
719: l_agent_list DBMS_AQ.aq$_agent_list_t;
720: l_agent SYS.aq$_agent;
721: l_index integer;
722: l_procedure VARCHAR2(200);
723: l_retval INTEGER;

Line 720: l_agent SYS.aq$_agent;

716: )
717:
718: IS
719: l_agent_list DBMS_AQ.aq$_agent_list_t;
720: l_agent SYS.aq$_agent;
721: l_index integer;
722: l_procedure VARCHAR2(200);
723: l_retval INTEGER;
724: e_listen_timeout EXCEPTION;

Line 749: l_agent_list(l_index) := SYS.aq$_agent ( r_subscriber.name

745:
746: -- okc_debug.Log('20: Before subscriber LOOP',2);
747:
748: FOR r_subscriber IN c_subscriber LOOP
749: l_agent_list(l_index) := SYS.aq$_agent ( r_subscriber.name
750: , OKC_AQ_PVT.g_outcome_queue_name
751: , NULL );
752:
753: -- okc_debug.Log('21: Index : '||l_index,2);

Line 1519: l_subscriber sys.aq$_agent;

1515: p_sub_name IN VARCHAR2
1516: , p_queue_name IN VARCHAR2
1517: , p_rule IN VARCHAR2 )
1518: IS
1519: l_subscriber sys.aq$_agent;
1520: l_sub_name VARCHAR2(2000);
1521: --
1522: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'add_subscriber';
1523: --

Line 1533: l_subscriber := sys.aq$_agent (l_sub_name,null,null);

1529: END IF;
1530:
1531: -- code the sub name by replacing dots with hash
1532: code_dots (p_sub_name, l_sub_name);
1533: l_subscriber := sys.aq$_agent (l_sub_name,null,null);
1534: DBMS_AQADM.add_subscriber ( p_queue_name
1535: , l_subscriber
1536: , p_rule );
1537: END add_subscriber;

Line 1545: l_subscriber SYS.aq$_agent;

1541: p_sub_name IN VARCHAR2
1542: , p_queue_name IN VARCHAR2 )
1543: IS
1544: l_sub_name VARCHAR2(2000);
1545: l_subscriber SYS.aq$_agent;
1546: --
1547: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'remove_subscriber';
1548: --
1549:

Line 1557: l_subscriber := sys.aq$_agent (l_sub_name,null,null);

1553: okc_debug.Log('10: Entering ',2);
1554: END IF;
1555:
1556: code_dots (p_sub_name, l_sub_name);
1557: l_subscriber := sys.aq$_agent (l_sub_name,null,null);
1558: DBMS_AQADM.remove_subscriber ( p_queue_name, l_subscriber);
1559:
1560: IF (l_debug = 'Y') THEN
1561: okc_debug.Log('1000: Leaving ',2);