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 OKC_API

Line 260: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

256: )
257: IS
258: l_api_name CONSTANT VARCHAR2(30) := 'SEND_MESSAGE';
259: l_api_version CONSTANT NUMBER := 1.0;
260: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
261: l_xml_clob system.okc_aq_msg_typ;
262: x_msg_handle RAW(16);
263: OKC_ENQUEUE_FAILED EXCEPTION;
264: PRAGMA EXCEPTION_INIT (OKC_ENQUEUE_FAILED, -99095 );

Line 277: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

273: END IF;
274:
275: -- Call start_activity to create savepoint, check compatibility
276: -- and initialize message list
277: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
278: , g_pkg_name
279: , p_init_msg_list
280: , l_api_version
281: , p_api_version

Line 291: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

287: okc_debug.Log('20: l_return_status : '||l_return_status,2);
288: END IF;
289:
290: -- Check if activity started successfully
291: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
292: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
293: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
294: RAISE OKC_API.G_EXCEPTION_ERROR;
295: END IF;

Line 292: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

288: END IF;
289:
290: -- Check if activity started successfully
291: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
292: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
293: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
294: RAISE OKC_API.G_EXCEPTION_ERROR;
295: END IF;
296: IF p_corrid_rec.corrid IS NOT NULL AND

Line 293: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

289:
290: -- Check if activity started successfully
291: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
292: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
293: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
294: RAISE OKC_API.G_EXCEPTION_ERROR;
295: END IF;
296: IF p_corrid_rec.corrid IS NOT NULL AND
297: p_msg_tab.count > 0 THEN

Line 294: RAISE OKC_API.G_EXCEPTION_ERROR;

290: -- Check if activity started successfully
291: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
292: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
293: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
294: RAISE OKC_API.G_EXCEPTION_ERROR;
295: END IF;
296: IF p_corrid_rec.corrid IS NOT NULL AND
297: p_msg_tab.count > 0 THEN
298:

Line 339: OKC_API.END_ACTIVITY ( x_msg_count

335: END IF;
336: RAISE OKC_ENQUEUE_FAILED;
337: END IF;
338: -- end activity
339: OKC_API.END_ACTIVITY ( x_msg_count
340: , x_msg_data );
341: IF (l_debug = 'Y') THEN
342: okc_debug.Log('1000: Leaving ',2);
343: okc_debug.Reset_Indentation;

Line 348: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN

344: END IF;
345:
346:
347: EXCEPTION
348: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
349: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
350: l_api_name
351: , g_pkg_name
352: , 'OKC_API.G_EXCEPTION_UNEXPECTED_ERROR'

Line 349: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

345:
346:
347: EXCEPTION
348: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
349: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
350: l_api_name
351: , g_pkg_name
352: , 'OKC_API.G_EXCEPTION_UNEXPECTED_ERROR'
353: , x_msg_count

Line 352: , 'OKC_API.G_EXCEPTION_UNEXPECTED_ERROR'

348: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
349: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
350: l_api_name
351: , g_pkg_name
352: , 'OKC_API.G_EXCEPTION_UNEXPECTED_ERROR'
353: , x_msg_count
354: , x_msg_data
355: , '_PVT'
356: );

Line 362: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

358: okc_debug.Log('2000: Leaving ',2);
359: okc_debug.Reset_Indentation;
360: END IF;
361: WHEN OTHERS THEN
362: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
363: l_api_name
364: , g_pkg_name
365: , 'OTHERS'
366: , x_msg_count

Line 391: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

387: )
388: IS
389: l_api_name CONSTANT VARCHAR2(30) := 'SEND_MESSAGE';
390: l_api_version CONSTANT NUMBER := 1.0;
391: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
392: l_char_clob system.okc_aq_msg_typ;
393: x_msg_handle RAW(16);
394: OKC_ENQUEUE_FAILED EXCEPTION;
395: PRAGMA EXCEPTION_INIT (OKC_ENQUEUE_FAILED, -99095 );

Line 409: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

405:
406: IF p_msg IS NOT NULL THEN
407: -- Call start_activity to create savepoint, check compatibility
408: -- and initialize message list
409: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
410: , g_pkg_name
411: , p_init_msg_list
412: , l_api_version
413: , p_api_version

Line 418: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

414: , '_PVT'
415: , x_return_status
416: );
417: -- Check if activity started successfully
418: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
419: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
420: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
421: RAISE OKC_API.G_EXCEPTION_ERROR;
422: END IF;

Line 419: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

415: , x_return_status
416: );
417: -- Check if activity started successfully
418: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
419: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
420: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
421: RAISE OKC_API.G_EXCEPTION_ERROR;
422: END IF;
423:

Line 420: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

416: );
417: -- Check if activity started successfully
418: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
419: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
420: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
421: RAISE OKC_API.G_EXCEPTION_ERROR;
422: END IF;
423:
424: -- build character clob

Line 421: RAISE OKC_API.G_EXCEPTION_ERROR;

417: -- Check if activity started successfully
418: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
419: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
420: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
421: RAISE OKC_API.G_EXCEPTION_ERROR;
422: END IF;
423:
424: -- build character clob
425: build_char_clob ( p_msg, l_char_clob );

Line 437: OKC_API.END_ACTIVITY ( x_msg_count

433: IF x_msg_handle IS NULL THEN
434: RAISE OKC_ENQUEUE_FAILED;
435: END IF;
436: -- end activity
437: OKC_API.END_ACTIVITY ( x_msg_count
438: , x_msg_data );
439: END IF;
440: IF (l_debug = 'Y') THEN
441: okc_debug.Log('1000: Leaving ',2);

Line 447: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN

443: END IF;
444:
445:
446: EXCEPTION
447: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
448: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
449: l_api_name
450: , g_pkg_name
451: , 'OKC_API.G_RET_STS_ERROR'

Line 448: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

444:
445:
446: EXCEPTION
447: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
448: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
449: l_api_name
450: , g_pkg_name
451: , 'OKC_API.G_RET_STS_ERROR'
452: , x_msg_count

Line 451: , 'OKC_API.G_RET_STS_ERROR'

447: WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
448: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
449: l_api_name
450: , g_pkg_name
451: , 'OKC_API.G_RET_STS_ERROR'
452: , x_msg_count
453: , x_msg_data
454: , '_PVT'
455: );

Line 461: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

457: okc_debug.Log('2000: Leaving ',2);
458: okc_debug.Reset_Indentation;
459: END IF;
460: WHEN OTHERS THEN
461: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
462: l_api_name
463: , g_pkg_name
464: , 'OTHERS'
465: , x_msg_count

Line 835: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

831: l_msg_data VARCHAR2(1000);
832: l_msg_count NUMBER;
833: v_msg_data VARCHAR2(1000);
834: v_msg_count NUMBER;
835: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
836: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_EVENT';
837: l_api_version CONSTANT NUMBER := 1.0;
838: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
839: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

Line 838: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

834: v_msg_count NUMBER;
835: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
836: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_EVENT';
837: l_api_version CONSTANT NUMBER := 1.0;
838: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
839: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
840: x_msg_count NUMBER;
841: x_msg_data VARCHAR2(1000);
842: l_token1 VARCHAR2(50);

Line 839: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

835: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
836: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_EVENT';
837: l_api_version CONSTANT NUMBER := 1.0;
838: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
839: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
840: x_msg_count NUMBER;
841: x_msg_data VARCHAR2(1000);
842: l_token1 VARCHAR2(50);
843: l_token1_value VARCHAR2(50);

Line 870: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

866: END IF;
867:
868: -- Call start_activity to create savepoint, check compatibility
869: -- and initialize message list
870: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
871: , g_pkg_name
872: , OKC_API.G_FALSE
873: , l_api_version
874: , 1.0

Line 872: , OKC_API.G_FALSE

868: -- Call start_activity to create savepoint, check compatibility
869: -- and initialize message list
870: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
871: , g_pkg_name
872: , OKC_API.G_FALSE
873: , l_api_version
874: , 1.0
875: , '_PVT'
876: , x_return_status

Line 883: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

879: okc_debug.Log('20: l_return_status : '||l_return_status,2);
880: END IF;
881:
882: -- Check if activity started successfully
883: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
884: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
885: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
886: RAISE OKC_API.G_EXCEPTION_ERROR;
887: END IF;

Line 884: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

880: END IF;
881:
882: -- Check if activity started successfully
883: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
884: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
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

Line 885: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

881:
882: -- Check if activity started successfully
883: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
884: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
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);

Line 886: RAISE OKC_API.G_EXCEPTION_ERROR;

882: -- Check if activity started successfully
883: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
884: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
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;

Line 915: OKC_API.SET_MESSAGE(p_app_name => g_app_name

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
915: OKC_API.SET_MESSAGE(p_app_name => g_app_name
916: ,p_msg_name => 'OKC_REMOVE_MSG'
917: ,p_token1 => 'MSG_ID'
918: ,p_token1_value => RAWTOHEX(l_msg_handle)
919: ,p_token2 => 'CORRID'

Line 959: IF NVL(l_return_status,'X') = OKC_API.G_RET_STS_SUCCESS THEN

955: END IF;
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

Line 975: ELSIF NVL(l_return_status,'X') <> OKC_API.G_RET_STS_SUCCESS THEN

971: -- after 30 minutes of delay_retry time period and can be evaluated
972: -- again for a max_retry of 5 times. After 5th try if the evaluation
973: -- still fails then message is moved to exception queue.
974: -------------------------------------------------------------------------
975: ELSIF NVL(l_return_status,'X') <> OKC_API.G_RET_STS_SUCCESS THEN
976: OKC_API.SET_MESSAGE(p_app_name => g_app_name
977: ,p_msg_name => 'OKC_PROCESS_FAILED'
978: ,p_token1 => 'SOURCE'
979: ,p_token1_value => 'Condition Evaluator'

Line 976: OKC_API.SET_MESSAGE(p_app_name => g_app_name

972: -- again for a max_retry of 5 times. After 5th try if the evaluation
973: -- still fails then message is moved to exception queue.
974: -------------------------------------------------------------------------
975: ELSIF NVL(l_return_status,'X') <> OKC_API.G_RET_STS_SUCCESS THEN
976: OKC_API.SET_MESSAGE(p_app_name => g_app_name
977: ,p_msg_name => 'OKC_PROCESS_FAILED'
978: ,p_token1 => 'SOURCE'
979: ,p_token1_value => 'Condition Evaluator'
980: ,p_token2 => 'PROCESS'

Line 993: OKC_API.END_ACTIVITY ( l_msg_count

989: , msgid => l_msg_handle );
990: raise OKC_PROCESS_FAILED;
991: END IF;
992: -- end activity
993: OKC_API.END_ACTIVITY ( l_msg_count
994: , l_msg_data );
995:
996: IF (l_debug = 'Y') THEN
997: okc_debug.Log('100: l_msg_count : '||l_msg_count,2);

Line 1026: p_init_msg_list => OKC_API.G_TRUE,

1022: , msgid => l_msg_handle );
1023: commit;
1024: OKC_AQ_WRITE_ERROR_PVT.WRITE_MSGDATA(
1025: p_api_version => 1.0,
1026: p_init_msg_list => OKC_API.G_TRUE,
1027: p_source_name => 'Advanced Queuing',
1028: p_datetime => sysdate,
1029: p_msg_tab => l_msg_tab,
1030: p_q_name => 'Events Queue',

Line 1042: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

1038: okc_debug.Reset_Indentation;
1039: END IF;
1040:
1041: WHEN OTHERS THEN
1042: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
1043: l_api_name
1044: , g_pkg_name
1045: , 'OTHERS'
1046: , x_msg_count

Line 1052: p_init_msg_list => OKC_API.G_TRUE,

1048: , '_PVT'
1049: );
1050: OKC_AQ_WRITE_ERROR_PVT.WRITE_MSGDATA(
1051: p_api_version => 1.0,
1052: p_init_msg_list => OKC_API.G_TRUE,
1053: p_source_name => 'Advanced Queuing',
1054: p_datetime => sysdate,
1055: p_msg_tab => l_msg_tab,
1056: p_q_name => 'Events Queue',

Line 1085: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

1081: l_msg_data VARCHAR2(1000);
1082: l_msg_count NUMBER;
1083: v_msg_data VARCHAR2(1000);
1084: v_msg_count NUMBER;
1085: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1086: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_DATE_EVENT';
1087: l_api_version CONSTANT NUMBER := 1.0;
1088: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1089: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

Line 1088: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

1084: v_msg_count NUMBER;
1085: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1086: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_DATE_EVENT';
1087: l_api_version CONSTANT NUMBER := 1.0;
1088: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1089: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1090: x_msg_count NUMBER;
1091: x_msg_data VARCHAR2(1000);
1092: l_token1 VARCHAR2(50);

Line 1089: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

1085: v_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1086: l_api_name CONSTANT VARCHAR2(30) := 'DEQUEUE_DATE_EVENT';
1087: l_api_version CONSTANT NUMBER := 1.0;
1088: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1089: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
1090: x_msg_count NUMBER;
1091: x_msg_data VARCHAR2(1000);
1092: l_token1 VARCHAR2(50);
1093: l_token1_value VARCHAR2(50);

Line 1115: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

1111:
1112:
1113: -- Call start_activity to create savepoint, check compatibility
1114: -- and initialize message list
1115: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1116: , g_pkg_name
1117: , OKC_API.G_FALSE
1118: , l_api_version
1119: , 1.0

Line 1117: , OKC_API.G_FALSE

1113: -- Call start_activity to create savepoint, check compatibility
1114: -- and initialize message list
1115: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1116: , g_pkg_name
1117: , OKC_API.G_FALSE
1118: , l_api_version
1119: , 1.0
1120: , '_PVT'
1121: , x_return_status

Line 1124: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

1120: , '_PVT'
1121: , x_return_status
1122: );
1123: -- Check if activity started successfully
1124: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1125: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1126: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1127: RAISE OKC_API.G_EXCEPTION_ERROR;
1128: END IF;

Line 1125: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

1121: , x_return_status
1122: );
1123: -- Check if activity started successfully
1124: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1125: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
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

Line 1126: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

1122: );
1123: -- Check if activity started successfully
1124: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1125: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
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);

Line 1127: RAISE OKC_API.G_EXCEPTION_ERROR;

1123: -- Check if activity started successfully
1124: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1125: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
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;

Line 1147: OKC_API.SET_MESSAGE(p_app_name => g_app_name

1143: , payload => l_msg
1144: , msgid => l_msg_handle );
1145: -- if the payload is null then remove message from the queue and commit
1146: IF l_msg IS NULL THEN
1147: OKC_API.SET_MESSAGE(p_app_name => g_app_name
1148: ,p_msg_name => 'OKC_REMOVE_MSG'
1149: ,p_token1 => 'MSG_ID'
1150: ,p_token1_value => RAWTOHEX(l_msg_handle)
1151: ,p_token2 => 'CORRID'

Line 1178: IF NVL(l_return_status,'X') = OKC_API.G_RET_STS_SUCCESS THEN

1174: p_msg_tab =>l_msg_tab
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

Line 1194: ELSIF NVL(l_return_status,'X') <> OKC_API.G_RET_STS_SUCCESS THEN

1190: -- after 30 minutes of delay_retry time period and can be evaluated
1191: -- again for a max_retry of 5 times. After 5th try if the evaluation
1192: -- still fails then message is moved to exception queue.
1193: -------------------------------------------------------------------------
1194: ELSIF NVL(l_return_status,'X') <> OKC_API.G_RET_STS_SUCCESS THEN
1195: OKC_API.SET_MESSAGE(p_app_name => g_app_name
1196: ,p_msg_name => 'OKC_PROCESS_FAILED'
1197: ,p_token1 => 'SOURCE'
1198: ,p_token1_value => 'Condition Evaluator'

Line 1195: OKC_API.SET_MESSAGE(p_app_name => g_app_name

1191: -- again for a max_retry of 5 times. After 5th try if the evaluation
1192: -- still fails then message is moved to exception queue.
1193: -------------------------------------------------------------------------
1194: ELSIF NVL(l_return_status,'X') <> OKC_API.G_RET_STS_SUCCESS THEN
1195: OKC_API.SET_MESSAGE(p_app_name => g_app_name
1196: ,p_msg_name => 'OKC_PROCESS_FAILED'
1197: ,p_token1 => 'SOURCE'
1198: ,p_token1_value => 'Condition Evaluator'
1199: ,p_token2 => 'PROCESS'

Line 1212: OKC_API.END_ACTIVITY ( l_msg_count

1208: , msgid => l_msg_handle );
1209: raise OKC_PROCESS_FAILED;
1210: END IF;
1211: -- end activity
1212: OKC_API.END_ACTIVITY ( l_msg_count
1213: , l_msg_data );
1214:
1215: IF (l_debug = 'Y') THEN
1216: okc_debug.Log('1000: Leaving ',2);

Line 1240: p_init_msg_list => OKC_API.G_TRUE,

1236: , msgid => l_msg_handle );
1237: commit;
1238: OKC_AQ_WRITE_ERROR_PVT.WRITE_MSGDATA(
1239: p_api_version => 1.0,
1240: p_init_msg_list => OKC_API.G_TRUE,
1241: p_source_name => 'Advanced Queuing',
1242: p_datetime => sysdate,
1243: p_msg_tab => l_msg_tab,
1244: p_q_name => 'Events Queue',

Line 1256: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

1252: okc_debug.Reset_Indentation;
1253: END IF;
1254:
1255: WHEN OTHERS THEN
1256: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
1257: l_api_name
1258: , g_pkg_name
1259: , 'OTHERS'
1260: , x_msg_count

Line 1266: p_init_msg_list => OKC_API.G_TRUE,

1262: , '_PVT'
1263: );
1264: OKC_AQ_WRITE_ERROR_PVT.WRITE_MSGDATA(
1265: p_api_version => 1.0,
1266: p_init_msg_list => OKC_API.G_TRUE,
1267: p_source_name => 'Advanced Queuing',
1268: p_datetime => sysdate,
1269: p_msg_tab => l_msg_tab,
1270: p_q_name => 'Events Queue',

Line 1292: l_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;

1288: l_sub_name varchar2(30);
1289: l_msg_text varchar2(1000);
1290: l_msg_data varchar2(1000);
1291: l_msg_count number;
1292: l_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;
1293: x_msg_data varchar2(1000);
1294: x_msg_count number;
1295: x_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;
1296: v_msg_data varchar2(1000);

Line 1295: x_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;

1291: l_msg_count number;
1292: l_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;
1293: x_msg_data varchar2(1000);
1294: x_msg_count number;
1295: x_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;
1296: v_msg_data varchar2(1000);
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';

Line 1298: v_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;

1294: x_msg_count number;
1295: x_return_status varchar2(1) := OKC_API.G_RET_STS_SUCCESS;
1296: v_msg_data varchar2(1000);
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;

Line 1303: l_init_msg_list VARCHAR2(1) := okc_api.G_FALSE;

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);
1307: l_token2_value VARCHAR2(50);

Line 1327: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

1323:
1324:
1325: -- Call start_activity to create savepoint, check compatibility
1326: -- and initialize message list
1327: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1328: , g_pkg_name
1329: , OKC_API.G_FALSE
1330: , l_api_version
1331: , 1.0

Line 1329: , OKC_API.G_FALSE

1325: -- Call start_activity to create savepoint, check compatibility
1326: -- and initialize message list
1327: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1328: , g_pkg_name
1329: , OKC_API.G_FALSE
1330: , l_api_version
1331: , 1.0
1332: , '_PVT'
1333: , x_return_status

Line 1336: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

1332: , '_PVT'
1333: , x_return_status
1334: );
1335: -- Check if activity started successfully
1336: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1337: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1338: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1339: RAISE OKC_API.G_EXCEPTION_ERROR;
1340: END IF;

Line 1337: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

1333: , x_return_status
1334: );
1335: -- Check if activity started successfully
1336: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1337: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1338: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1339: RAISE OKC_API.G_EXCEPTION_ERROR;
1340: END IF;
1341:

Line 1338: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

1334: );
1335: -- Check if activity started successfully
1336: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1337: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1338: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1339: RAISE OKC_API.G_EXCEPTION_ERROR;
1340: END IF;
1341:
1342: IF (l_debug = 'Y') THEN

Line 1339: RAISE OKC_API.G_EXCEPTION_ERROR;

1335: -- Check if activity started successfully
1336: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1337: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1338: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1339: RAISE OKC_API.G_EXCEPTION_ERROR;
1340: END IF;
1341:
1342: IF (l_debug = 'Y') THEN
1343: okc_debug.Log('50: Calling code_dots ',2);

Line 1373: OKC_API.SET_MESSAGE(p_app_name => g_app_name

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
1374: ,p_msg_name => 'OKC_DEQUEUE_FAILED'
1375: ,p_token1 => 'MSG_ID'
1376: ,p_token1_value => RAWTOHEX(l_msg_handle)
1377: ,p_token2 => 'QUEUE'

Line 1402: p_init_msg_list => OKC_API.G_FALSE,

1398: -- call the outcome APIs
1399: IF l_corrid.corrid IS NOT NULL AND
1400: l_msg_tab.count <> 0 THEN
1401: OKC_OUTCOME_INIT_PVT.Launch_outcome(p_api_version => 1.0,
1402: p_init_msg_list => OKC_API.G_FALSE,
1403: p_corrid_rec => l_corrid,
1404: p_msg_tab_typ => l_msg_tab,
1405: x_msg_count => l_msg_count,
1406: x_msg_data => l_msg_data,

Line 1410: IF NVL(l_return_status,'X') = OKC_API.G_RET_STS_SUCCESS THEN

1406: x_msg_data => l_msg_data,
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

Line 1420: OKC_API.SET_MESSAGE(p_app_name => g_app_name

1416: , payload => l_msg
1417: , msgid => l_msg_handle );
1418: commit;
1419: ELSE
1420: OKC_API.SET_MESSAGE(p_app_name => g_app_name
1421: ,p_msg_name => 'OKC_PROCESS_FAILED'
1422: ,p_token1 => 'SOURCE'
1423: ,p_token1_value => 'Outcome Initiator'
1424: ,p_token2 => 'PROCESS'

Line 1438: OKC_API.END_ACTIVITY ( l_msg_count

1434: RAISE OKC_PROCESS_FAILED;
1435: END IF;
1436:
1437: -- end activity
1438: OKC_API.END_ACTIVITY ( l_msg_count
1439: , l_msg_data );
1440:
1441:
1442: IF (l_debug = 'Y') THEN

Line 1472: p_init_msg_list => OKC_API.G_TRUE,

1468: , msgid => l_msg_handle );
1469: commit;
1470: OKC_AQ_WRITE_ERROR_PVT.WRITE_MSGDATA(
1471: p_api_version => 1.0,
1472: p_init_msg_list => OKC_API.G_TRUE,
1473: p_source_name => 'Advanced Queuing',
1474: p_datetime => sysdate,
1475: p_msg_tab => l_msg_tab,
1476: p_q_name => 'Outcome Queue',

Line 1488: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

1484: okc_debug.Reset_Indentation;
1485: END IF;
1486:
1487: WHEN OTHERS THEN
1488: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
1489: l_api_name
1490: , g_pkg_name
1491: , 'OTHERS'
1492: , x_msg_count

Line 1498: p_init_msg_list => OKC_API.G_TRUE,

1494: , '_PVT'
1495: );
1496: OKC_AQ_WRITE_ERROR_PVT.WRITE_MSGDATA(
1497: p_api_version => 1.0,
1498: p_init_msg_list => OKC_API.G_TRUE,
1499: p_source_name => 'Advanced Queuing',
1500: p_datetime => sysdate,
1501: p_msg_tab => l_msg_tab,
1502: p_q_name => 'Outcome Queue',

Line 1581: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

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;
1583: x_msg_count NUMBER;
1584: x_msg_data VARCHAR2(1000);
1585: l_token1 VARCHAR2(50);

Line 1582: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

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;
1583: x_msg_count NUMBER;
1584: x_msg_data VARCHAR2(1000);
1585: l_token1 VARCHAR2(50);
1586: l_token1_value VARCHAR2(50);

Line 1616: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

1612:
1613: retcode := 0;
1614: -- Call start_activity to create savepoint, check compatibility
1615: -- and initialize message list
1616: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1617: , g_pkg_name
1618: , OKC_API.G_FALSE
1619: , l_api_version
1620: , 1.0

Line 1618: , OKC_API.G_FALSE

1614: -- Call start_activity to create savepoint, check compatibility
1615: -- and initialize message list
1616: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1617: , g_pkg_name
1618: , OKC_API.G_FALSE
1619: , l_api_version
1620: , 1.0
1621: , '_PVT'
1622: , x_return_status

Line 1625: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

1621: , '_PVT'
1622: , x_return_status
1623: );
1624: -- Check if activity started successfully
1625: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1626: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1627: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1628: RAISE OKC_API.G_EXCEPTION_ERROR;
1629: END IF;

Line 1626: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

1622: , x_return_status
1623: );
1624: -- Check if activity started successfully
1625: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1626: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1627: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1628: RAISE OKC_API.G_EXCEPTION_ERROR;
1629: END IF;
1630:

Line 1627: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

1623: );
1624: -- Check if activity started successfully
1625: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1626: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1627: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1628: RAISE OKC_API.G_EXCEPTION_ERROR;
1629: END IF;
1630:
1631: -- get the consumer name to enqueue message

Line 1628: RAISE OKC_API.G_EXCEPTION_ERROR;

1624: -- Check if activity started successfully
1625: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1626: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1627: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1628: RAISE OKC_API.G_EXCEPTION_ERROR;
1629: END IF;
1630:
1631: -- get the consumer name to enqueue message
1632: OPEN msg_cur;

Line 1656: OKC_API.SET_MESSAGE(p_app_name => g_app_name

1652: , payload => l_msg
1653: , msgid => l_msg_handle);
1654: -- if the payload is null then remove message from the queue and commit
1655: IF l_msg IS NULL THEN
1656: OKC_API.SET_MESSAGE(p_app_name => g_app_name
1657: ,p_msg_name => 'OKC_REMOVE_MSG'
1658: ,p_token1 => 'MSG_ID'
1659: ,p_token1_value => RAWTOHEX(l_msg_handle)
1660: ,p_token2 => 'CORRID'

Line 1682: OKC_API.END_ACTIVITY ( x_msg_count

1678: , l_msg_handle);
1679: END IF;
1680: commit;
1681: -- end activity
1682: OKC_API.END_ACTIVITY ( x_msg_count
1683: , x_msg_data );
1684:
1685: IF (l_debug = 'Y') THEN
1686: okc_debug.Log('1000: Leaving ',2);

Line 1703: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

1699:
1700: WHEN OTHERS THEN
1701: retcode := 2;
1702: errbuf := substr(sqlerrm,1,250);
1703: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
1704: l_api_name
1705: , g_pkg_name
1706: , 'OTHERS'
1707: , x_msg_count

Line 1736: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

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;
1738: x_msg_count NUMBER;
1739: x_msg_data VARCHAR2(1000);
1740: l_token1 VARCHAR2(50);

Line 1737: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

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;
1738: x_msg_count NUMBER;
1739: x_msg_data VARCHAR2(1000);
1740: l_token1 VARCHAR2(50);
1741: l_token1_value VARCHAR2(50);

Line 1773: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

1769:
1770: retcode := 0;
1771: -- Call start_activity to create savepoint, check compatibility
1772: -- and initialize message list
1773: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1774: , g_pkg_name
1775: , OKC_API.G_FALSE
1776: , l_api_version
1777: , 1.0

Line 1775: , OKC_API.G_FALSE

1771: -- Call start_activity to create savepoint, check compatibility
1772: -- and initialize message list
1773: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1774: , g_pkg_name
1775: , OKC_API.G_FALSE
1776: , l_api_version
1777: , 1.0
1778: , '_PVT'
1779: , x_return_status

Line 1782: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

1778: , '_PVT'
1779: , x_return_status
1780: );
1781: -- Check if activity started successfully
1782: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1783: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1784: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1785: RAISE OKC_API.G_EXCEPTION_ERROR;
1786: END IF;

Line 1783: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

1779: , x_return_status
1780: );
1781: -- Check if activity started successfully
1782: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1783: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1784: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1785: RAISE OKC_API.G_EXCEPTION_ERROR;
1786: END IF;
1787:

Line 1784: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

1780: );
1781: -- Check if activity started successfully
1782: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1783: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1784: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1785: RAISE OKC_API.G_EXCEPTION_ERROR;
1786: END IF;
1787:
1788: -- get the consumer name to enqueue message

Line 1785: RAISE OKC_API.G_EXCEPTION_ERROR;

1781: -- Check if activity started successfully
1782: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1783: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1784: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1785: RAISE OKC_API.G_EXCEPTION_ERROR;
1786: END IF;
1787:
1788: -- get the consumer name to enqueue message
1789: OPEN msg_cur;

Line 1821: OKC_API.END_ACTIVITY ( x_msg_count

1817: , msgid => l_msg_handle);
1818:
1819: commit;
1820: -- end activity
1821: OKC_API.END_ACTIVITY ( x_msg_count
1822: , x_msg_data );
1823:
1824: IF (l_debug = 'Y') THEN
1825: okc_debug.Log('1000: Leaving ',2);

Line 1842: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

1838:
1839: WHEN OTHERS THEN
1840: retcode := 2;
1841: errbuf := substr(sqlerrm,1,250);
1842: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
1843: l_api_name
1844: , g_pkg_name
1845: , 'OTHERS'
1846: , x_msg_count

Line 1869: l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

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;
1871: x_msg_count NUMBER;
1872: x_msg_data VARCHAR2(1000);
1873: l_token1 VARCHAR2(50);

Line 1870: x_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;

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;
1871: x_msg_count NUMBER;
1872: x_msg_data VARCHAR2(1000);
1873: l_token1 VARCHAR2(50);
1874: l_token1_value VARCHAR2(50);

Line 1916: l_return_status := OKC_API.START_ACTIVITY ( l_api_name

1912:
1913: retcode := 0;
1914: -- Call start_activity to create savepoint, check compatibility
1915: -- and initialize message list
1916: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1917: , g_pkg_name
1918: , OKC_API.G_FALSE
1919: , l_api_version
1920: , 1.0

Line 1918: , OKC_API.G_FALSE

1914: -- Call start_activity to create savepoint, check compatibility
1915: -- and initialize message list
1916: l_return_status := OKC_API.START_ACTIVITY ( l_api_name
1917: , g_pkg_name
1918: , OKC_API.G_FALSE
1919: , l_api_version
1920: , 1.0
1921: , '_PVT'
1922: , x_return_status

Line 1925: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN

1921: , '_PVT'
1922: , x_return_status
1923: );
1924: -- Check if activity started successfully
1925: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1926: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1927: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1928: RAISE OKC_API.G_EXCEPTION_ERROR;
1929: END IF;

Line 1926: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;

1922: , x_return_status
1923: );
1924: -- Check if activity started successfully
1925: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1926: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1927: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1928: RAISE OKC_API.G_EXCEPTION_ERROR;
1929: END IF;
1930:

Line 1927: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN

1923: );
1924: -- Check if activity started successfully
1925: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1926: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1927: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1928: RAISE OKC_API.G_EXCEPTION_ERROR;
1929: END IF;
1930:
1931: OPEN profile_cur;

Line 1928: RAISE OKC_API.G_EXCEPTION_ERROR;

1924: -- Check if activity started successfully
1925: IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
1926: RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
1927: ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
1928: RAISE OKC_API.G_EXCEPTION_ERROR;
1929: END IF;
1930:
1931: OPEN profile_cur;
1932: FETCH profile_cur INTO profile_rec;

Line 1966: OKC_API.END_ACTIVITY ( x_msg_count

1962: END IF;
1963: END LOOP;
1964: CLOSE msg_cur;
1965: -- end activity
1966: OKC_API.END_ACTIVITY ( x_msg_count
1967: , x_msg_data );
1968:
1969: IF (l_debug = 'Y') THEN
1970: okc_debug.Log('1000: Leaving ',2);

Line 1987: x_return_status := OKC_API.HANDLE_EXCEPTIONS (

1983:
1984: WHEN OTHERS THEN
1985: retcode := 2;
1986: errbuf := substr(sqlerrm,1,250);
1987: x_return_status := OKC_API.HANDLE_EXCEPTIONS (
1988: l_api_name
1989: , g_pkg_name
1990: , 'OTHERS'
1991: , x_msg_count

Line 2025: l_return_status := OKC_API.G_RET_STS_SUCCESS;

2021: okc_debug.Log('10: Entering ',2);
2022: END IF;
2023:
2024: --Initialize return status
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'