[Home] [Help]
1: Package body OKC_AQ_PVT AS
2: /* $Header: OKCRAQB.pls 120.0 2005/05/25 18:34:40 appldev noship $ */
3:
4: l_debug VARCHAR2(1) := NVL(FND_PROFILE.VALUE('AFLOG_ENABLED'),'N');
5: ---------------------------------------------------------------------------
7: ---------------------------------------------------------------------------
8: -- TYPES
9: ---------------------------------------------------------------------------
10: -- CONSTANTS
11: g_pkg_name constant varchar2(100) := 'OKC_AQ_PVT';
12: ---------------------------------------------------------------------------
13: -- PUBLIC VARIABLES
14: ---------------------------------------------------------------------------
15: -- EXCEPTIONS
33: acn_rec acn_cur%ROWTYPE;
34: v_acn_type okc_actions_b.acn_type%TYPE;
35:
36: --
37: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'get_acn_type';
38: --
39:
40: BEGIN
41: IF (l_debug = 'Y') THEN
84: v_msg_prop dbms_aq.message_properties_t;
85: v_msg_handle raw(16);
86: v_recipient_list DBMS_AQ.aq$_recipient_list_t;
87: --
88: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'enqueue_message';
89: --
90:
91: BEGIN
92: IF (l_debug = 'Y') THEN
95: END IF;
96:
97:
98: v_msg_prop.recipient_list := v_recipient_list;
99: v_msg_prop.expiration := okc_aq_pvt.g_msg_expire;
100: v_msg_prop.correlation := p_corrid_rec.corrid;
101: v_msg_prop.delay := p_delay;
102: v_nq_options.visibility := dbms_aq.ON_COMMIT;
103: DBMS_AQ.enqueue ( queue_name => p_queue_name
120: x_char_clob OUT NOCOPY system.okc_aq_msg_typ )
121: IS
122: l_char_clob system.okc_aq_msg_typ;
123: --
124: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'build_char_clob';
125: --
126:
127: BEGIN
128: IF (l_debug = 'Y') THEN
160: IS
161: l_amount INTEGER;
162: l_clob_msg system.okc_aq_msg_typ;
163: --
164: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'clob_to_char';
165: --
166:
167: BEGIN
168: IF (l_debug = 'Y') THEN
191: p_name IN VARCHAR2 ,
192: x_name OUT NOCOPY VARCHAR2 )
193: IS
194: --
195: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'code_dots';
196: --
197:
198: BEGIN
199: IF (l_debug = 'Y') THEN
216: p_name IN VARCHAR2
217: , x_name OUT NOCOPY VARCHAR2 )
218: IS
219: --
220: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'decode_dots';
221: --
222:
223: BEGIN
224: IF (l_debug = 'Y') THEN
262: x_msg_handle RAW(16);
263: OKC_ENQUEUE_FAILED EXCEPTION;
264: PRAGMA EXCEPTION_INIT (OKC_ENQUEUE_FAILED, -99095 );
265: --
266: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'send_message';
267: --
268:
269: BEGIN
270: IF (l_debug = 'Y') THEN
393: x_msg_handle RAW(16);
394: OKC_ENQUEUE_FAILED EXCEPTION;
395: PRAGMA EXCEPTION_INIT (OKC_ENQUEUE_FAILED, -99095 );
396: --
397: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'send_message';
398: --
399:
400: BEGIN
401: IF (l_debug = 'Y') THEN
507: queue_rec queue_cur%ROWTYPE;
508:
509:
510: --
511: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'shutdown_event_listener';
512: --
513:
514: BEGIN
515: -- okc_debug.Set_Indentation(l_proc);
579: queue_rec queue_cur%ROWTYPE;
580:
581:
582: --
583: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'shutdown_outcome_listener';
584: --
585:
586: BEGIN
587: -- okc_debug.Set_Indentation(l_proc);
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: --
646:
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: --
646:
647: BEGIN
648: -- okc_debug.Set_Indentation(l_proc);
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;
662:
673:
674: /* bug 2258913 - shut down cursor performs poorly when queue load is high
675: Shutdown process no longer needed as listener no longer runs infinately.
676:
677: IF shutdown_event_listener(OKC_AQ_PVT.g_event_queue_name) THEN
678: EXIT;
679: ELSE
680: */
681:
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: --
738:
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: --
738:
739: BEGIN
740: -- okc_debug.Set_Indentation(l_proc);
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);
754:
768:
769: /* bug 2258913 - shut down cursor performs poorly when queue load is high
770: Shutdown process no longer needed as listener no longer runs infinately.
771:
772: IF shutdown_outcome_listener(OKC_AQ_PVT.g_outcome_queue_name) THEN
773: IF (l_debug = 'Y') THEN
774: okc_debug.Log('45: Inside unconditional LOOP - exiting ',2);
775: END IF;
776: EXIT;
823: l_msg_prop dbms_aq.message_properties_t;
824: l_msg_handle raw(16);
825: l_msg system.okc_aq_msg_typ;
826: l_sub_name varchar2(30);
827: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
828: l_corrid OKC_AQ_PVT.corrid_rec_typ;
829: l_acn_id OKC_ACTIONS_V.ID%TYPE;
830: l_msg_text VARCHAR2(1000);
831: l_msg_data VARCHAR2(1000);
824: l_msg_handle raw(16);
825: l_msg system.okc_aq_msg_typ;
826: l_sub_name varchar2(30);
827: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
828: l_corrid OKC_AQ_PVT.corrid_rec_typ;
829: l_acn_id OKC_ACTIONS_V.ID%TYPE;
830: l_msg_text VARCHAR2(1000);
831: l_msg_data VARCHAR2(1000);
832: l_msg_count NUMBER;
854: OKC_DEQUEUE_FAILED EXCEPTION;
855: OKC_REMOVE_MSG EXCEPTION;
856:
857: --
858: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'dequeue_event';
859: --
860:
861: BEGIN
862:
885: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
886: RAISE OKC_API.G_EXCEPTION_ERROR;
887: END IF;
888: -- convert dots to hashes to make sub name legal
889: code_dots ('OKC_AQ_PVT.DEQUEUE_EVENT', l_sub_name);
890: l_dq_options.consumer_name := l_sub_name;
891: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
892: l_dq_options.navigation := dbms_aq.first_message;
893: l_dq_options.dequeue_mode := dbms_aq.LOCKED;
887: END IF;
888: -- convert dots to hashes to make sub name legal
889: code_dots ('OKC_AQ_PVT.DEQUEUE_EVENT', l_sub_name);
890: l_dq_options.consumer_name := l_sub_name;
891: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
892: l_dq_options.navigation := dbms_aq.first_message;
893: l_dq_options.dequeue_mode := dbms_aq.LOCKED;
894: l_dq_options.visibility := dbms_aq.on_commit;
895:
895:
896:
897: IF (l_debug = 'Y') THEN
898: okc_debug.Log('30: Calling DBMS_AQ.dequeue with following parameters',2);
899: okc_debug.Log('30: queue_name : '||OKC_AQ_PVT.g_event_queue_name,2);
900: END IF;
901:
902: -- get the message from the queue
903: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
899: okc_debug.Log('30: queue_name : '||OKC_AQ_PVT.g_event_queue_name,2);
900: END IF;
901:
902: -- get the message from the queue
903: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
904: , dequeue_options => l_dq_options
905: , message_properties => l_msg_prop
906: , payload => l_msg
907: , msgid => l_msg_handle );
958: -- and commit the transaction
959: IF NVL(l_return_status,'X') = OKC_API.G_RET_STS_SUCCESS THEN
960: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
961: l_dq_options.msgid := l_msg_handle;
962: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
963: , dequeue_options => l_dq_options
964: , message_properties => l_msg_prop
965: , payload => l_msg
966: , msgid => l_msg_handle );
981: ,p_token2_value => 'Evaluate Condition'
982: );
983: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
984: l_dq_options.msgid := l_msg_handle;
985: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
986: , dequeue_options => l_dq_options
987: , message_properties => l_msg_prop
988: , payload => l_msg
989: , msgid => l_msg_handle );
1014: null;
1015: WHEN OKC_REMOVE_MSG THEN
1016: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
1017: l_dq_options.msgid := l_msg_handle;
1018: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
1019: , dequeue_options => l_dq_options
1020: , message_properties => l_msg_prop
1021: , payload => l_msg
1022: , msgid => l_msg_handle );
1073: l_msg_prop dbms_aq.message_properties_t;
1074: l_msg_handle raw(16);
1075: l_msg system.okc_aq_msg_typ;
1076: l_sub_name varchar2(30);
1077: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
1078: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1079: l_cnh_id OKC_CONDITION_HEADERS_B.ID%TYPE;
1080: l_msg_text VARCHAR2(1000);
1081: l_msg_data VARCHAR2(1000);
1074: l_msg_handle raw(16);
1075: l_msg system.okc_aq_msg_typ;
1076: l_sub_name varchar2(30);
1077: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
1078: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1079: l_cnh_id OKC_CONDITION_HEADERS_B.ID%TYPE;
1080: l_msg_text VARCHAR2(1000);
1081: l_msg_data VARCHAR2(1000);
1082: l_msg_count NUMBER;
1099: OKC_DEQUEUE_FAILED EXCEPTION;
1100: OKC_REMOVE_MSG EXCEPTION;
1101:
1102: --
1103: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'dequeue_date_event';
1104: --
1105:
1106: BEGIN
1107: IF (l_debug = 'Y') THEN
1126: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1127: RAISE OKC_API.G_EXCEPTION_ERROR;
1128: END IF;
1129: -- convert dots to hashes to make sub name legal
1130: code_dots ('OKC_AQ_PVT.DEQUEUE_DATE_EVENT', l_sub_name);
1131: l_dq_options.consumer_name := l_sub_name;
1132: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
1133: l_dq_options.navigation := dbms_aq.first_message;
1134: l_dq_options.dequeue_mode := dbms_aq.LOCKED;
1128: END IF;
1129: -- convert dots to hashes to make sub name legal
1130: code_dots ('OKC_AQ_PVT.DEQUEUE_DATE_EVENT', l_sub_name);
1131: l_dq_options.consumer_name := l_sub_name;
1132: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
1133: l_dq_options.navigation := dbms_aq.first_message;
1134: l_dq_options.dequeue_mode := dbms_aq.LOCKED;
1135: l_dq_options.visibility := dbms_aq.on_commit;
1136:
1136:
1137:
1138: -- get the message from the queue
1139:
1140: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
1141: , dequeue_options => l_dq_options
1142: , message_properties => l_msg_prop
1143: , payload => l_msg
1144: , msgid => l_msg_handle );
1177: -- and commit the transaction
1178: IF NVL(l_return_status,'X') = OKC_API.G_RET_STS_SUCCESS THEN
1179: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
1180: l_dq_options.msgid := l_msg_handle;
1181: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
1182: , dequeue_options => l_dq_options
1183: , message_properties => l_msg_prop
1184: , payload => l_msg
1185: , msgid => l_msg_handle );
1200: ,p_token2_value => 'Evaluate Date Condition'
1201: );
1202: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
1203: l_dq_options.msgid := l_msg_handle;
1204: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
1205: , dequeue_options => l_dq_options
1206: , message_properties => l_msg_prop
1207: , payload => l_msg
1208: , msgid => l_msg_handle );
1228: null;
1229: WHEN OKC_REMOVE_MSG THEN
1230: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
1231: l_dq_options.msgid := l_msg_handle;
1232: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name
1233: , dequeue_options => l_dq_options
1234: , message_properties => l_msg_prop
1235: , payload => l_msg
1236: , msgid => l_msg_handle );
1297: v_msg_count number;
1298: v_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;
1299: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_OUTCOME';
1300: l_api_version CONSTANT NUMBER := 1.0;
1301: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
1302: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1303: l_init_msg_list VARCHAR2(1) := okc_api.G_FALSE;
1304: l_token1 VARCHAR2(50);
1305: l_token1_value VARCHAR2(50);
1298: v_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;
1299: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_OUTCOME';
1300: l_api_version CONSTANT NUMBER := 1.0;
1301: l_msg_tab OKC_AQ_PVT.msg_tab_typ;
1302: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1303: l_init_msg_list VARCHAR2(1) := okc_api.G_FALSE;
1304: l_token1 VARCHAR2(50);
1305: l_token1_value VARCHAR2(50);
1306: l_token2 VARCHAR2(50);
1311: OKC_DEQUEUE_FAILED EXCEPTION;
1312: OKC_REMOVE_MSG EXCEPTION;
1313:
1314: --
1315: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'dequeue_outcome';
1316: --
1317:
1318: BEGIN
1319: IF (l_debug = 'Y') THEN
1343: okc_debug.Log('50: Calling code_dots ',2);
1344: END IF;
1345:
1346: -- convert dots to hashes to make sub name legal
1347: code_dots ('OKC_AQ_PVT.DEQUEUE_OUTCOME', l_sub_name);
1348:
1349: l_dq_options.consumer_name := l_sub_name;
1350: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
1351: l_dq_options.navigation := dbms_aq.next_message;
1346: -- convert dots to hashes to make sub name legal
1347: code_dots ('OKC_AQ_PVT.DEQUEUE_OUTCOME', l_sub_name);
1348:
1349: l_dq_options.consumer_name := l_sub_name;
1350: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
1351: l_dq_options.navigation := dbms_aq.next_message;
1352: l_dq_options.dequeue_mode := dbms_aq.LOCKED;
1353: l_dq_options.visibility := dbms_aq.ON_COMMIT;
1354:
1358: END IF;
1359:
1360: -- get the message from the queue
1361:
1362: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name
1363: , dequeue_options => l_dq_options
1364: , message_properties => l_msg_prop
1365: , payload => l_msg
1366: , msgid => l_msg_handle );
1409: END IF;
1410: IF NVL(l_return_status,'X') = OKC_API.G_RET_STS_SUCCESS THEN
1411: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
1412: l_dq_options.msgid := l_msg_handle;
1413: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name
1414: , dequeue_options => l_dq_options
1415: , message_properties => l_msg_prop
1416: , payload => l_msg
1417: , msgid => l_msg_handle );
1425: ,p_token2_value => 'Launch Outcome'
1426: );
1427: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
1428: l_dq_options.msgid := l_msg_handle;
1429: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name
1430: , dequeue_options => l_dq_options
1431: , message_properties => l_msg_prop
1432: , payload => l_msg
1433: , msgid => l_msg_handle );
1460: null;
1461: WHEN OKC_REMOVE_MSG THEN
1462: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
1463: l_dq_options.msgid := l_msg_handle;
1464: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name
1465: , dequeue_options => l_dq_options
1466: , message_properties => l_msg_prop
1467: , payload => l_msg
1468: , msgid => l_msg_handle );
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: --
1524:
1525: BEGIN
1526: IF (l_debug = 'Y') THEN
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:
1550: BEGIN
1551: IF (l_debug = 'Y') THEN
1574: l_msg_prop dbms_aq.message_properties_t;
1575: l_msg_handle raw(16);
1576: l_msg system.okc_aq_msg_typ;
1577: l_sub_name varchar2(30);
1578: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1579: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_EXCEPTION';
1580: l_api_version CONSTANT NUMBER := 1.0;
1581: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1582: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1599: PRAGMA EXCEPTION_INIT (e_dequeue_timeout, -25228 );
1600: OKC_REMOVE_MSG EXCEPTION;
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
1637: END IF;
1638: CLOSE msg_cur;
1639:
1640: l_dq_options.consumer_name := null;
1641: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
1642: l_dq_options.navigation := dbms_aq.next_message;
1643: l_dq_options.dequeue_mode := dbms_aq.REMOVE;
1644: l_dq_options.visibility := dbms_aq.on_commit;
1645: l_dq_options.msgid := HEXTORAW(p_msg_id);
1663: raise OKC_REMOVE_MSG;
1664: END IF;
1665:
1666: -- enqueue the message into appropriate queue based on consumer name
1667: IF l_consumer_name = 'OKC_AQ_PVT#DEQUEUE_OUTCOME' THEN
1668: enqueue_message ( l_msg
1669: , l_corrid
1670: ,OKC_AQ_PVT.g_outcome_queue_name
1671: ,dbms_aq.no_delay
1666: -- enqueue the message into appropriate queue based on consumer name
1667: IF l_consumer_name = 'OKC_AQ_PVT#DEQUEUE_OUTCOME' THEN
1668: enqueue_message ( l_msg
1669: , l_corrid
1670: ,OKC_AQ_PVT.g_outcome_queue_name
1671: ,dbms_aq.no_delay
1672: , l_msg_handle);
1673: ELSE
1674: enqueue_message ( l_msg
1672: , l_msg_handle);
1673: ELSE
1674: enqueue_message ( l_msg
1675: , l_corrid
1676: ,OKC_AQ_PVT.g_event_queue_name
1677: ,dbms_aq.no_delay
1678: , l_msg_handle);
1679: END IF;
1680: commit;
1729: l_msg_prop dbms_aq.message_properties_t;
1730: l_msg_handle raw(16);
1731: l_msg system.okc_aq_msg_typ;
1732: l_sub_name varchar2(30);
1733: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1734: l_api_name CONSTANT VARCHAR2(30) := 'REMOVE_MESSAGE';
1735: l_api_version CONSTANT NUMBER := 1.0;
1736: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1737: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1756: PRAGMA EXCEPTION_INIT (e_dequeue_timeout, -25228 );
1757: OKC_REMOVE_MSG EXCEPTION;
1758:
1759: --
1760: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'remove_message';
1761: --
1762:
1763: BEGIN
1764: IF (l_debug = 'Y') THEN
1794: l_queue := msg_rec.queue;
1795: END IF;
1796: CLOSE msg_cur;
1797: l_dq_options.consumer_name := l_consumer_name;
1798: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
1799: l_dq_options.navigation := dbms_aq.next_message;
1800: l_dq_options.dequeue_mode := dbms_aq.REMOVE;
1801: l_dq_options.visibility := dbms_aq.on_commit;
1802: l_dq_options.msgid := HEXTORAW(p_msg_id);
1801: l_dq_options.visibility := dbms_aq.on_commit;
1802: l_dq_options.msgid := HEXTORAW(p_msg_id);
1803:
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;
1803:
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:
1862: l_msg_prop dbms_aq.message_properties_t;
1863: l_msg_handle raw(16);
1864: l_msg system.okc_aq_msg_typ;
1865: l_sub_name varchar2(30);
1866: l_corrid OKC_AQ_PVT.corrid_rec_typ;
1867: l_api_name CONSTANT VARCHAR2(30) := 'REMOVE_MESSAGE';
1868: l_api_version CONSTANT NUMBER := 1.0;
1869: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1870: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1898: PRAGMA EXCEPTION_INIT (e_dequeue_timeout, -25228 );
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
1943: EXIT;
1944: ELSE
1945:
1946: l_dq_options.consumer_name := null;
1947: l_dq_options.wait := OKC_AQ_PVT.g_dequeue_wait;
1948: l_dq_options.navigation := dbms_aq.next_message;
1949: l_dq_options.dequeue_mode := dbms_aq.REMOVE;
1950: l_dq_options.visibility := dbms_aq.on_commit;
1951: l_dq_options.msgid := HEXTORAW(msg_rec.msgid);
2000:
2001: -- This procedure will be executed by ICM at the time of database shutdown
2002: PROCEDURE stop_listener
2003: IS
2004: l_corrid_rec okc_aq_pvt.corrid_rec_typ;
2005: l_msg_tab okc_aq_pvt.msg_tab_typ := okc_aq_pvt.msg_tab_typ() ;
2006: l_msg_count number;
2007: l_msg_data varchar2(1000);
2008: l_return_status varchar2(1);
2001: -- This procedure will be executed by ICM at the time of database shutdown
2002: PROCEDURE stop_listener
2003: IS
2004: l_corrid_rec okc_aq_pvt.corrid_rec_typ;
2005: l_msg_tab okc_aq_pvt.msg_tab_typ := okc_aq_pvt.msg_tab_typ() ;
2006: l_msg_count number;
2007: l_msg_data varchar2(1000);
2008: l_return_status varchar2(1);
2009: x_msg_count number;
2011: x_return_status varchar2(1);
2012: l_api_name CONSTANT VARCHAR2(30) := 'STOP_LISTENER';
2013: PRAGMA AUTONOMOUS_TRANSACTION;
2014: --
2015: l_proc varchar2(72) := ' OKC_AQ_PVT.'||'stop_listener';
2016: --
2017:
2018: BEGIN
2019: IF (l_debug = 'Y') THEN
2025: l_return_status := OKC_API.G_RET_STS_SUCCESS;
2026:
2027: l_corrid_rec.corrid := 'SHUTDOWN';
2028: -- enqueues shutdown message into events queue
2029: okc_aq_pvt.send_message ( p_api_version => '1.0'
2030: , x_msg_count => l_msg_count
2031: , x_msg_data => l_msg_data
2032: , x_return_status => l_return_status
2033: , p_corrid_rec => l_corrid_rec
2031: , x_msg_data => l_msg_data
2032: , x_return_status => l_return_status
2033: , p_corrid_rec => l_corrid_rec
2034: , p_msg_tab => l_msg_tab
2035: , p_queue_name => okc_aq_pvt.g_event_queue_name );
2036:
2037: -- enqueues shutdown message into outcomes queue
2038: okc_aq_pvt.send_message ( p_api_version => '1.0'
2039: , x_msg_count => l_msg_count
2034: , p_msg_tab => l_msg_tab
2035: , p_queue_name => okc_aq_pvt.g_event_queue_name );
2036:
2037: -- enqueues shutdown message into outcomes queue
2038: okc_aq_pvt.send_message ( p_api_version => '1.0'
2039: , x_msg_count => l_msg_count
2040: , x_msg_data => l_msg_data
2041: , x_return_status => l_return_status
2042: , p_corrid_rec => l_corrid_rec
2040: , x_msg_data => l_msg_data
2041: , x_return_status => l_return_status
2042: , p_corrid_rec => l_corrid_rec
2043: , p_msg_tab => l_msg_tab
2044: , p_queue_name => okc_aq_pvt.g_outcome_queue_name );
2045: commit;
2046:
2047: IF (l_debug = 'Y') THEN
2048: okc_debug.Log('1000: Leaving ',2);
2058: END IF;
2059: rollback;
2060: END stop_listener;
2061:
2062: END okc_aq_pvt;