eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.OKC_AQ_PVT dependencies on DBMS_AQ

Line 83: v_nq_options dbms_aq.enqueue_options_t;

79: , p_queue_name IN VARCHAR2
80: , p_delay IN NUMBER
81: , x_msg_handle OUT NOCOPY RAW)
82: IS
83: v_nq_options dbms_aq.enqueue_options_t;
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: --

Line 84: v_msg_prop dbms_aq.message_properties_t;

80: , p_delay IN NUMBER
81: , x_msg_handle OUT NOCOPY RAW)
82: IS
83: v_nq_options dbms_aq.enqueue_options_t;
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';

Line 86: v_recipient_list DBMS_AQ.aq$_recipient_list_t;

82: IS
83: v_nq_options dbms_aq.enqueue_options_t;
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:

Line 102: v_nq_options.visibility := dbms_aq.ON_COMMIT;

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
104: , enqueue_options => v_nq_options
105: , message_properties => v_msg_prop
106: , payload => p_clob_msg

Line 103: DBMS_AQ.enqueue ( queue_name => p_queue_name

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
104: , enqueue_options => v_nq_options
105: , message_properties => v_msg_prop
106: , payload => p_clob_msg
107: , msgid => v_msg_handle );

Line 481: l_dq_options dbms_aq.dequeue_options_t;

477: -- else returns false.
478: FUNCTION shutdown_event_listener(p_queue IN VARCHAR2) RETURN boolean
479: IS
480:
481: l_dq_options dbms_aq.dequeue_options_t;
482: l_msg_prop dbms_aq.message_properties_t;
483: l_msg_handle raw(16);
484: l_msg system.okc_aq_msg_typ;
485: CURSOR queue_cur

Line 482: l_msg_prop dbms_aq.message_properties_t;

478: FUNCTION shutdown_event_listener(p_queue IN VARCHAR2) RETURN boolean
479: IS
480:
481: l_dq_options dbms_aq.dequeue_options_t;
482: l_msg_prop dbms_aq.message_properties_t;
483: l_msg_handle raw(16);
484: l_msg system.okc_aq_msg_typ;
485: CURSOR queue_cur
486: IS

Line 526: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

522: OPEN queue_cur;
523: FETCH queue_cur INTO queue_rec;
524: IF queue_cur%FOUND THEN
525: l_dq_options.consumer_name := queue_rec.consumer_name;
526: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
527: l_dq_options.msgid := queue_rec.msgid;
528: DBMS_AQ.dequeue ( queue_name => p_queue
529: , dequeue_options => l_dq_options
530: , message_properties => l_msg_prop

Line 528: DBMS_AQ.dequeue ( queue_name => p_queue

524: IF queue_cur%FOUND THEN
525: l_dq_options.consumer_name := queue_rec.consumer_name;
526: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
527: l_dq_options.msgid := queue_rec.msgid;
528: DBMS_AQ.dequeue ( queue_name => p_queue
529: , dequeue_options => l_dq_options
530: , message_properties => l_msg_prop
531: , payload => l_msg
532: , msgid => l_msg_handle );

Line 554: l_dq_options dbms_aq.dequeue_options_t;

550: -- else returns false.
551: FUNCTION shutdown_outcome_listener(p_queue IN VARCHAR2) RETURN boolean
552: IS
553:
554: l_dq_options dbms_aq.dequeue_options_t;
555: l_msg_prop dbms_aq.message_properties_t;
556: l_msg_handle raw(16);
557: l_msg system.okc_aq_msg_typ;
558: CURSOR queue_cur

Line 555: l_msg_prop dbms_aq.message_properties_t;

551: FUNCTION shutdown_outcome_listener(p_queue IN VARCHAR2) RETURN boolean
552: IS
553:
554: l_dq_options dbms_aq.dequeue_options_t;
555: l_msg_prop dbms_aq.message_properties_t;
556: l_msg_handle raw(16);
557: l_msg system.okc_aq_msg_typ;
558: CURSOR queue_cur
559: IS

Line 599: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

595: FETCH queue_cur INTO queue_rec;
596: IF queue_cur%FOUND THEN
597:
598: l_dq_options.consumer_name := queue_rec.consumer_name;
599: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
600: l_dq_options.msgid := queue_rec.msgid;
601: DBMS_AQ.dequeue ( queue_name => p_queue
602: , dequeue_options => l_dq_options
603: , message_properties => l_msg_prop

Line 601: DBMS_AQ.dequeue ( queue_name => p_queue

597:
598: l_dq_options.consumer_name := queue_rec.consumer_name;
599: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
600: l_dq_options.msgid := queue_rec.msgid;
601: DBMS_AQ.dequeue ( queue_name => p_queue
602: , dequeue_options => l_dq_options
603: , message_properties => l_msg_prop
604: , payload => l_msg
605: , msgid => l_msg_handle );

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 683: DBMS_AQ.listen ( agent_list => l_agent_list

679: ELSE
680: */
681:
682: BEGIN
683: DBMS_AQ.listen ( agent_list => l_agent_list
684: , wait => p_wait
685: , agent => l_agent );
686: decode_dots ( l_agent.name, l_procedure );
687: execute immediate 'begin '||l_procedure||'; end;';

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 781: -- okc_debug.Log('52: Calling DBMS_AQ.listen',2);

777: ELSE
778: */
779: -- okc_debug.Log('46: Inside unconditional LOOP at 46 ',2);
780: BEGIN
781: -- okc_debug.Log('52: Calling DBMS_AQ.listen',2);
782:
783: DBMS_AQ.listen ( agent_list => l_agent_list
784: , wait => p_wait
785: , agent => l_agent );

Line 783: DBMS_AQ.listen ( agent_list => l_agent_list

779: -- okc_debug.Log('46: Inside unconditional LOOP at 46 ',2);
780: BEGIN
781: -- okc_debug.Log('52: Calling DBMS_AQ.listen',2);
782:
783: DBMS_AQ.listen ( agent_list => l_agent_list
784: , wait => p_wait
785: , agent => l_agent );
786:
787: -- okc_debug.Log('53: Calling decode_dots',2);

Line 822: l_dq_options dbms_aq.dequeue_options_t;

818:
819:
820: PROCEDURE dequeue_event
821: IS
822: l_dq_options dbms_aq.dequeue_options_t;
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);

Line 823: l_msg_prop dbms_aq.message_properties_t;

819:
820: PROCEDURE dequeue_event
821: IS
822: l_dq_options dbms_aq.dequeue_options_t;
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;

Line 892: l_dq_options.navigation := dbms_aq.first_message;

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:
896:

Line 893: l_dq_options.dequeue_mode := dbms_aq.LOCKED;

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:
896:
897: IF (l_debug = 'Y') THEN

Line 894: l_dq_options.visibility := dbms_aq.on_commit;

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:
896:
897: IF (l_debug = 'Y') THEN
898: okc_debug.Log('30: Calling DBMS_AQ.dequeue with following parameters',2);

Line 898: okc_debug.Log('30: Calling DBMS_AQ.dequeue with following parameters',2);

894: l_dq_options.visibility := dbms_aq.on_commit;
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

Line 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 );

Line 910: okc_debug.Log('40: After Call to DBMS_AQ.dequeue',2);

906: , payload => l_msg
907: , msgid => l_msg_handle );
908:
909: IF (l_debug = 'Y') THEN
910: okc_debug.Log('40: After Call to DBMS_AQ.dequeue',2);
911: END IF;
912:
913: -- if the payload is null then remove message from the queue and commit
914: IF l_msg IS NULL THEN

Line 960: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

956:
957: -- if evaluation is successfull then remove message from the queue
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

Line 962: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name

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 );

Line 983: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

979: ,p_token1_value => 'Condition Evaluator'
980: ,p_token2 => 'PROCESS'
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

Line 985: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name

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 );

Line 1016: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

1012: okc_debug.Reset_Indentation;
1013: END IF;
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

Line 1018: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name

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 );

Line 1072: l_dq_options dbms_aq.dequeue_options_t;

1068:
1069: -- This procedure deques all actions that are Date Based Actions
1070: PROCEDURE dequeue_date_event
1071: IS
1072: l_dq_options dbms_aq.dequeue_options_t;
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);

Line 1073: l_msg_prop dbms_aq.message_properties_t;

1069: -- This procedure deques all actions that are Date Based Actions
1070: PROCEDURE dequeue_date_event
1071: IS
1072: l_dq_options dbms_aq.dequeue_options_t;
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;

Line 1133: l_dq_options.navigation := dbms_aq.first_message;

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:
1137:

Line 1134: l_dq_options.dequeue_mode := dbms_aq.LOCKED;

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:
1137:
1138: -- get the message from the queue

Line 1135: l_dq_options.visibility := dbms_aq.on_commit;

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:
1137:
1138: -- get the message from the queue
1139:

Line 1140: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name

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 );

Line 1179: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

1175: );
1176: -- if evaluation is successfull then remove message from the queue
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

Line 1181: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name

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 );

Line 1202: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

1198: ,p_token1_value => 'Condition Evaluator'
1199: ,p_token2 => 'PROCESS'
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

Line 1204: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name

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 );

Line 1230: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

1226: okc_debug.Reset_Indentation;
1227: END IF;
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

Line 1232: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_event_queue_name

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 );

Line 1284: l_dq_options dbms_aq.dequeue_options_t;

1280: END dequeue_date_event;
1281:
1282: PROCEDURE dequeue_outcome
1283: IS
1284: l_dq_options dbms_aq.dequeue_options_t;
1285: l_msg_prop dbms_aq.message_properties_t;
1286: l_msg_handle raw(16);
1287: l_msg system.okc_aq_msg_typ;
1288: l_sub_name varchar2(30);

Line 1285: l_msg_prop dbms_aq.message_properties_t;

1281:
1282: PROCEDURE dequeue_outcome
1283: IS
1284: l_dq_options dbms_aq.dequeue_options_t;
1285: l_msg_prop dbms_aq.message_properties_t;
1286: l_msg_handle raw(16);
1287: l_msg system.okc_aq_msg_typ;
1288: l_sub_name varchar2(30);
1289: l_msg_text varchar2(1000);

Line 1351: l_dq_options.navigation := dbms_aq.next_message;

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:
1355:

Line 1352: l_dq_options.dequeue_mode := dbms_aq.LOCKED;

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:
1355:
1356: IF (l_debug = 'Y') THEN

Line 1353: l_dq_options.visibility := dbms_aq.ON_COMMIT;

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:
1355:
1356: IF (l_debug = 'Y') THEN
1357: okc_debug.Log('100: Calling DBMS_AQ.dequeue',2);

Line 1357: okc_debug.Log('100: Calling DBMS_AQ.dequeue',2);

1353: l_dq_options.visibility := dbms_aq.ON_COMMIT;
1354:
1355:
1356: IF (l_debug = 'Y') THEN
1357: okc_debug.Log('100: Calling DBMS_AQ.dequeue',2);
1358: END IF;
1359:
1360: -- get the message from the queue
1361:

Line 1362: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name

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 );

Line 1369: okc_debug.Log('110: After Calling DBMS_AQ.dequeue',2);

1365: , payload => l_msg
1366: , msgid => l_msg_handle );
1367:
1368: IF (l_debug = 'Y') THEN
1369: okc_debug.Log('110: After Calling DBMS_AQ.dequeue',2);
1370: END IF;
1371:
1372: IF l_msg IS NULL THEN
1373: OKC_API.SET_MESSAGE(p_app_name => g_app_name

Line 1411: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

1407: x_return_status => l_return_status
1408: );
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

Line 1413: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name

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 );

Line 1427: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

1423: ,p_token1_value => 'Outcome Initiator'
1424: ,p_token2 => 'PROCESS'
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

Line 1429: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name

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 );

Line 1462: l_dq_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

1458: okc_debug.Reset_Indentation;
1459: END IF;
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

Line 1464: DBMS_AQ.dequeue ( queue_name => OKC_AQ_PVT.g_outcome_queue_name

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 );

Line 1534: DBMS_AQADM.add_subscriber ( p_queue_name

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;
1538:

Line 1558: DBMS_AQADM.remove_subscriber ( p_queue_name, l_subscriber);

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);
1562: okc_debug.Reset_Indentation;

Line 1573: l_dq_options dbms_aq.dequeue_options_t;

1569: errbuf OUT NOCOPY VARCHAR2
1570: ,retcode OUT NOCOPY VARCHAR2
1571: ,p_msg_id IN VARCHAR2)
1572: IS
1573: l_dq_options dbms_aq.dequeue_options_t;
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);

Line 1574: l_msg_prop dbms_aq.message_properties_t;

1570: ,retcode OUT NOCOPY VARCHAR2
1571: ,p_msg_id IN VARCHAR2)
1572: IS
1573: l_dq_options dbms_aq.dequeue_options_t;
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;

Line 1642: l_dq_options.navigation := dbms_aq.next_message;

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);
1646:

Line 1643: l_dq_options.dequeue_mode := dbms_aq.REMOVE;

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);
1646:
1647:

Line 1644: l_dq_options.visibility := dbms_aq.on_commit;

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);
1646:
1647:
1648: -- get the message from the exception queue

Line 1649: DBMS_AQ.dequeue ( queue_name => l_queue_name

1645: l_dq_options.msgid := HEXTORAW(p_msg_id);
1646:
1647:
1648: -- get the message from the exception queue
1649: DBMS_AQ.dequeue ( queue_name => l_queue_name
1650: , dequeue_options => l_dq_options
1651: , message_properties => l_msg_prop
1652: , payload => l_msg
1653: , msgid => l_msg_handle);

Line 1671: ,dbms_aq.no_delay

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
1675: , l_corrid

Line 1677: ,dbms_aq.no_delay

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;
1681: -- end activity

Line 1728: l_dq_options dbms_aq.dequeue_options_t;

1724: errbuf OUT NOCOPY VARCHAR2
1725: ,retcode OUT NOCOPY VARCHAR2
1726: ,p_msg_id IN VARCHAR2)
1727: IS
1728: l_dq_options dbms_aq.dequeue_options_t;
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);

Line 1729: l_msg_prop dbms_aq.message_properties_t;

1725: ,retcode OUT NOCOPY VARCHAR2
1726: ,p_msg_id IN VARCHAR2)
1727: IS
1728: l_dq_options dbms_aq.dequeue_options_t;
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;

Line 1799: l_dq_options.navigation := dbms_aq.next_message;

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);
1803:

Line 1800: l_dq_options.dequeue_mode := dbms_aq.REMOVE;

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);
1803:
1804: IF l_queue = 'OKC_AQ_EV_QUEUE' THEN

Line 1801: l_dq_options.visibility := dbms_aq.on_commit;

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);
1803:
1804: IF l_queue = 'OKC_AQ_EV_QUEUE' THEN
1805: l_queue := okc_aq_pvt.g_event_queue_name;

Line 1813: DBMS_AQ.dequeue ( queue_name => l_queue

1809: l_queue := l_error_queue;
1810: END IF;
1811:
1812: -- get the message from the queue
1813: DBMS_AQ.dequeue ( queue_name => l_queue
1814: , dequeue_options => l_dq_options
1815: , message_properties => l_msg_prop
1816: , payload => l_msg
1817: , msgid => l_msg_handle);

Line 1861: l_dq_options dbms_aq.dequeue_options_t;

1857: PROCEDURE clear_message( errbuf OUT NOCOPY VARCHAR2
1858: ,retcode OUT NOCOPY VARCHAR2
1859: )
1860: IS
1861: l_dq_options dbms_aq.dequeue_options_t;
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);

Line 1862: l_msg_prop dbms_aq.message_properties_t;

1858: ,retcode OUT NOCOPY VARCHAR2
1859: )
1860: IS
1861: l_dq_options dbms_aq.dequeue_options_t;
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;

Line 1948: l_dq_options.navigation := dbms_aq.next_message;

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);
1952:

Line 1949: l_dq_options.dequeue_mode := dbms_aq.REMOVE;

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);
1952:
1953:

Line 1950: l_dq_options.visibility := dbms_aq.on_commit;

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);
1952:
1953:
1954: -- remove the message from the exception queue

Line 1955: DBMS_AQ.dequeue ( queue_name => l_error_queue

1951: l_dq_options.msgid := HEXTORAW(msg_rec.msgid);
1952:
1953:
1954: -- remove the message from the exception queue
1955: DBMS_AQ.dequeue ( queue_name => l_error_queue
1956: , dequeue_options => l_dq_options
1957: , message_properties => l_msg_prop
1958: , payload => l_msg
1959: , msgid => l_msg_handle);