APPS.OKC_AQ_PVT dependencies on OKC_AQ_EV_TAB

Line 490: from AQ$_OKC_AQ_EV_TAB_H h,

486: IS
487: SELECT h.msgid msgid ,
488: decode(h.subscriber#,0
489: ,decode(h.name,'0',NULL,h.name),s.name) consumer_name
490: from AQ$_OKC_AQ_EV_TAB_H h,
491: aq$_okc_aq_ev_tab_s s,
492: okc_aq_ev_tab q
493: WHERE q.q_name = substr(p_queue,5)
494: and q.STATE = 0

Line 491: aq$_okc_aq_ev_tab_s s,

487: SELECT h.msgid msgid ,
488: decode(h.subscriber#,0
489: ,decode(h.name,'0',NULL,h.name),s.name) consumer_name
490: from AQ$_OKC_AQ_EV_TAB_H h,
491: aq$_okc_aq_ev_tab_s s,
492: okc_aq_ev_tab q
493: WHERE q.q_name = substr(p_queue,5)
494: and q.STATE = 0
495: and h.msgid = q.msgid

Line 492: okc_aq_ev_tab q

488: decode(h.subscriber#,0
489: ,decode(h.name,'0',NULL,h.name),s.name) consumer_name
490: from AQ$_OKC_AQ_EV_TAB_H h,
491: aq$_okc_aq_ev_tab_s s,
492: okc_aq_ev_tab q
493: WHERE q.q_name = substr(p_queue,5)
494: and q.STATE = 0
495: and h.msgid = q.msgid
496: AND ( (h.subscriber# <> 0 AND h.subscriber# = s.subscriber_id)

Line 503: FROM aq$okc_aq_ev_tab

499: AND q.CORRID = 'SHUTDOWN';
500: /*
501: changed cursor for performance bug# 1563692
502: SELECT msg_id,consumer_name
503: FROM aq$okc_aq_ev_tab
504: WHERE 'OKC.'||queue = p_queue
505: AND msg_state = 'READY'
506: AND UPPER(corr_id) = 'SHUTDOWN';*/
507: queue_rec queue_cur%ROWTYPE;

Line 563: from AQ$_OKC_AQ_EV_TAB_H h,

559: IS
560: SELECT h.msgid msgid ,
561: decode(h.subscriber#,0
562: ,decode(h.name,'0',NULL,h.name),s.name) consumer_name
563: from AQ$_OKC_AQ_EV_TAB_H h,
564: aq$_okc_aq_ev_tab_s s,
565: okc_aq_ev_tab q
566: WHERE q.q_name = substr(p_queue,5)
567: and q.STATE = 0

Line 564: aq$_okc_aq_ev_tab_s s,

560: SELECT h.msgid msgid ,
561: decode(h.subscriber#,0
562: ,decode(h.name,'0',NULL,h.name),s.name) consumer_name
563: from AQ$_OKC_AQ_EV_TAB_H h,
564: aq$_okc_aq_ev_tab_s s,
565: okc_aq_ev_tab q
566: WHERE q.q_name = substr(p_queue,5)
567: and q.STATE = 0
568: and h.msgid = q.msgid

Line 565: okc_aq_ev_tab q

561: decode(h.subscriber#,0
562: ,decode(h.name,'0',NULL,h.name),s.name) consumer_name
563: from AQ$_OKC_AQ_EV_TAB_H h,
564: aq$_okc_aq_ev_tab_s s,
565: okc_aq_ev_tab q
566: WHERE q.q_name = substr(p_queue,5)
567: and q.STATE = 0
568: and h.msgid = q.msgid
569: AND ( (h.subscriber# <> 0 AND h.subscriber# = s.subscriber_id)

Line 575: FROM aq$okc_aq_ev_tab

571: (h.subscriber# = 0 AND h.address# = s.subscriber_id))
572: AND q.CORRID = 'SHUTDOWN';
573: --changed cursor for performance bug# 1563692
574: /*SELECT msg_id,consumer_name
575: FROM aq$okc_aq_ev_tab
576: WHERE 'OKC.'||queue = p_queue
577: AND msg_state = 'READY'
578: AND UPPER(corr_id) = 'SHUTDOWN';*/
579: queue_rec queue_cur%ROWTYPE;

Line 641: FROM AQ$OKC_AQ_EV_TAB_S

637: PRAGMA EXCEPTION_INIT ( e_listen_timeout, -25254);
638: -- bug 3621354 changed cursor to query subscriber view rather than table
639: CURSOR c_subscriber IS
640: SELECT name
641: FROM AQ$OKC_AQ_EV_TAB_S
642: WHERE queue = substr(OKC_AQ_PVT.g_event_queue_name,5);
643: --
644: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'listen_event';
645: --

Line 733: FROM AQ$OKC_AQ_EV_TAB_S

729:
730: -- bug 3621354 changed cursor to query subscriber view rather than table
731: CURSOR c_subscriber IS
732: SELECT name
733: FROM AQ$OKC_AQ_EV_TAB_S
734: WHERE queue = substr(OKC_AQ_PVT.g_outcome_queue_name,5);
735: --
736: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'listen_outcome';
737: --

Line 1594: FROM aq$okc_aq_ev_tab

1590:
1591:
1592: CURSOR msg_cur IS
1593: SELECT consumer_name,corr_id
1594: FROM aq$okc_aq_ev_tab
1595: WHERE msg_id = HEXTORAW(p_msg_id);
1596: msg_rec msg_cur%ROWTYPE;
1597:
1598: e_dequeue_timeout EXCEPTION;

Line 1605: l_queue_name varchar2(25) := g_app_name||'.AQ$_OKC_AQ_EV_TAB_E';

1601:
1602: --
1603: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'dequeue_exception';
1604: --
1605: l_queue_name varchar2(25) := g_app_name||'.AQ$_OKC_AQ_EV_TAB_E';
1606: BEGIN
1607: IF (l_debug = 'Y') THEN
1608: okc_debug.Set_Indentation(l_proc);
1609: okc_debug.Log('10: Entering ',2);

Line 1746: l_error_queue VARCHAR2(30) := g_app_name||'.AQ$_OKC_AQ_EV_TAB_E';

1742: l_token2 VARCHAR2(50);
1743: l_token2_value VARCHAR2(50);
1744: l_consumer_name VARCHAR2(50);
1745: l_queue VARCHAR2(30);
1746: l_error_queue VARCHAR2(30) := g_app_name||'.AQ$_OKC_AQ_EV_TAB_E';
1747:
1748:
1749: CURSOR msg_cur IS
1750: SELECT consumer_name,corr_id,queue

Line 1751: FROM aq$okc_aq_ev_tab

1747:
1748:
1749: CURSOR msg_cur IS
1750: SELECT consumer_name,corr_id,queue
1751: FROM aq$okc_aq_ev_tab
1752: WHERE msg_id = HEXTORAW(p_msg_id);
1753: msg_rec msg_cur%ROWTYPE;
1754:
1755: e_dequeue_timeout EXCEPTION;

Line 1808: ELSIF l_queue = 'AQ$_OKC_AQ_EV_TAB_E' THEN

1804: IF l_queue = 'OKC_AQ_EV_QUEUE' THEN
1805: l_queue := okc_aq_pvt.g_event_queue_name;
1806: ELSIF l_queue = 'OKC_AQ_OC_QUEUE' THEN
1807: l_queue := okc_aq_pvt.g_outcome_queue_name;
1808: ELSIF l_queue = 'AQ$_OKC_AQ_EV_TAB_E' THEN
1809: l_queue := l_error_queue;
1810: END IF;
1811:
1812: -- get the message from the queue

Line 1892: FROM okc_aq_ev_tab

1888: profile_rec profile_cur%ROWTYPE;
1889:
1890: CURSOR msg_cur(x IN NUMBER) IS
1891: SELECT msgid
1892: FROM okc_aq_ev_tab
1893: WHERE q_name = 'AQ$_OKC_AQ_EV_TAB_E'
1894: AND trunc(enq_time) + (x) = trunc(sysdate);
1895: msg_rec msg_cur%ROWTYPE;
1896:

Line 1893: WHERE q_name = 'AQ$_OKC_AQ_EV_TAB_E'

1889:
1890: CURSOR msg_cur(x IN NUMBER) IS
1891: SELECT msgid
1892: FROM okc_aq_ev_tab
1893: WHERE q_name = 'AQ$_OKC_AQ_EV_TAB_E'
1894: AND trunc(enq_time) + (x) = trunc(sysdate);
1895: msg_rec msg_cur%ROWTYPE;
1896:
1897: e_dequeue_timeout EXCEPTION;

Line 1903: l_error_queue varchar2(30) := g_app_name||'.AQ$_OKC_AQ_EV_TAB_E';

1899: OKC_REMOVE_MSG EXCEPTION;
1900:
1901: --
1902: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'clear_message';
1903: l_error_queue varchar2(30) := g_app_name||'.AQ$_OKC_AQ_EV_TAB_E';
1904: --
1905:
1906: BEGIN
1907: IF (l_debug = 'Y') THEN