APPS.MSC_CL_PRE_PROCESS dependencies on DBMS_PIPE

Line 55699: DBMS_PIPE.PACK_MESSAGE(lv_message);

55695: EXIT WHEN SQL%NOTFOUND ;
55696: commit;
55697:
55698: lv_message := to_char(p_task_name)||','||to_char(lv_batch_id);
55699: DBMS_PIPE.PACK_MESSAGE(lv_message);
55700: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
55701: RAISE EX_PIPE_SND;
55702: END IF;
55703: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'p_task_name: '||lv_message);

Line 55700: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

55696: commit;
55697:
55698: lv_message := to_char(p_task_name)||','||to_char(lv_batch_id);
55699: DBMS_PIPE.PACK_MESSAGE(lv_message);
55700: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
55701: RAISE EX_PIPE_SND;
55702: END IF;
55703: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'p_task_name: '||lv_message);
55704: lv_task_not_completed := lv_task_not_completed + 1;

Line 55716: DBMS_PIPE.PACK_MESSAGE(lv_message );

55712: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_WARNING,'Error in Sending message in Pipe');
55713: WHEN OTHERS THEN
55714: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_WARNING,'Error in Batch ID generation: ' || SQLERRM);
55715: lv_message := to_char(p_task_name)||','||to_char(0);
55716: DBMS_PIPE.PACK_MESSAGE(lv_message );
55717: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
55718: RAISE EX_PIPE_SND ;
55719: END IF;
55720: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_WARNING,'p_task_name: '||lv_message);

Line 55717: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

55713: WHEN OTHERS THEN
55714: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_WARNING,'Error in Batch ID generation: ' || SQLERRM);
55715: lv_message := to_char(p_task_name)||','||to_char(0);
55716: DBMS_PIPE.PACK_MESSAGE(lv_message );
55717: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
55718: RAISE EX_PIPE_SND ;
55719: END IF;
55720: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_WARNING,'p_task_name: '||lv_message);
55721: lv_task_not_completed := lv_task_not_completed + 1;

Line 57865: lv_pipe_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);

57861: END IF;
57862:
57863: -- ============= Get the Task from Task Que ==============
57864:
57865: lv_pipe_ret_code := DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_task_que, PIPE_TIME_OUT);
57866:
57867: IF lv_pipe_ret_code<>0 THEN
57868:
57869: IF lv_pipe_ret_code<> 1 THEN Raise EX_PIPE_RCV; END IF;

Line 57873: IF DBMS_PIPE.next_item_type = 0 then

57869: IF lv_pipe_ret_code<> 1 THEN Raise EX_PIPE_RCV; END IF;
57870:
57871: ELSE
57872:
57873: IF DBMS_PIPE.next_item_type = 0 then
57874:
57875: dbms_lock.sleep(2); -- sleep for 2 seconds and then check again
57876:
57877: ELSE

Line 57879: DBMS_PIPE.UNPACK_MESSAGE(lv_message);

57875: dbms_lock.sleep(2); -- sleep for 2 seconds and then check again
57876:
57877: ELSE
57878:
57879: DBMS_PIPE.UNPACK_MESSAGE(lv_message);
57880: lv_task_number := get_task_num (lv_message);
57881:
57882: IF lv_task_number< 0 or lv_task_number = TASK_ALL_COMPLETED then
57883: EXIT ;

Line 57894: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);

57890: lv_batch_id := get_batch_id(lv_message);
57891: EXECUTE_TASK( lv_task_status, lv_task_number, lv_batch_id );
57892:
57893: IF lv_task_status <> OK THEN
57894: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);
57895: ELSE
57896: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
57897: END IF;
57898:

Line 57896: DBMS_PIPE.PACK_MESSAGE( lv_task_number);

57892:
57893: IF lv_task_status <> OK THEN
57894: DBMS_PIPE.PACK_MESSAGE( -lv_task_number);
57895: ELSE
57896: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
57897: END IF;
57898:
57899: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
57900: RAISE EX_PIPE_SND;

Line 57899: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN

57895: ELSE
57896: DBMS_PIPE.PACK_MESSAGE( lv_task_number);
57897: END IF;
57898:
57899: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
57900: RAISE EX_PIPE_SND;
57901: END IF;
57902:
57903: IF lv_task_status <> OK THEN

Line 57918: DBMS_PIPE.PACK_MESSAGE( SYS_YES);

57914:
57915: IF lv_task_number = TASK_ALL_COMPLETED THEN
57916: COMMIT;
57917:
57918: DBMS_PIPE.PACK_MESSAGE( SYS_YES);
57919:
57920: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
57921: RAISE EX_PIPE_SND;
57922: END IF;

Line 57920: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN

57916: COMMIT;
57917:
57918: DBMS_PIPE.PACK_MESSAGE( SYS_YES);
57919:
57920: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
57921: RAISE EX_PIPE_SND;
57922: END IF;
57923:
57924: FND_MESSAGE.SET_NAME('MSC', 'MSC_PP_SUCCEED');

Line 57937: DBMS_PIPE.PACK_MESSAGE( SYS_YES);

57933: ELSE -- unknown error occurs
57934:
57935: ROLLBACK;
57936:
57937: DBMS_PIPE.PACK_MESSAGE( SYS_YES);
57938:
57939: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
57940: RAISE EX_PIPE_SND;
57941: END IF;

Line 57939: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN

57935: ROLLBACK;
57936:
57937: DBMS_PIPE.PACK_MESSAGE( SYS_YES);
57938:
57939: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
57940: RAISE EX_PIPE_SND;
57941: END IF;
57942:
57943: FND_MESSAGE.SET_NAME('MSC', 'MSC_PP_FAIL');

Line 57964: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

57960: RETCODE := G_ERROR;
57961: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ERRBUF);
57962:
57963: -- send a message of 'unresolvable error' to monitor
57964: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
57965:
57966: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
57967: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
57968: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);

Line 57966: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN

57962:
57963: -- send a message of 'unresolvable error' to monitor
57964: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
57965:
57966: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
57967: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
57968: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
57969: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,FND_MESSAGE.GET);
57970: END IF;

Line 57984: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

57980: RETCODE := G_ERROR;
57981: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,ERRBUF);
57982:
57983: -- send a message of 'unresolavable error' to monitor
57984: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
57985:
57986: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
57987: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
57988: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);

Line 57986: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN

57982:
57983: -- send a message of 'unresolavable error' to monitor
57984: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
57985:
57986: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
57987: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
57988: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
57989: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,FND_MESSAGE.GET);
57990: END IF;

Line 58003: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

57999: RETCODE := G_ERROR;
58000: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ERRBUF);
58001:
58002: -- send a message of 'unresolavable error' to monitor
58003: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
58004:
58005: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
58006: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
58007: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);

Line 58005: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN

58001:
58002: -- send a message of 'unresolavable error' to monitor
58003: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
58004:
58005: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
58006: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
58007: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
58008: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,FND_MESSAGE.GET);
58009: END IF;

Line 58021: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);

58017:
58018: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, ERRBUF);
58019:
58020: -- send a message of 'unresolavable error' to monitor
58021: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
58022:
58023: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
58024: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
58025: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);

Line 58023: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN

58019:
58020: -- send a message of 'unresolavable error' to monitor
58021: DBMS_PIPE.PACK_MESSAGE( UNRESOVLABLE_ERROR);
58022:
58023: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_wm)<>0 THEN
58024: FND_MESSAGE.SET_NAME('MSC', 'MSC_MSG_SEND_FAIL');
58025: FND_MESSAGE.SET_TOKEN('PIPE', v_pipe_wm);
58026: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,FND_MESSAGE.GET);
58027: END IF;

Line 58030: DBMS_PIPE.PACK_MESSAGE( SYS_YES);

58026: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,FND_MESSAGE.GET);
58027: END IF;
58028:
58029: -- send a message of 'the worker ends its process' to monitor
58030: DBMS_PIPE.PACK_MESSAGE( SYS_YES);
58031:
58032: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
58033: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'FAIL TO SEND MESSAGE');
58034: END IF;

Line 58032: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN

58028:
58029: -- send a message of 'the worker ends its process' to monitor
58030: DBMS_PIPE.PACK_MESSAGE( SYS_YES);
58031:
58032: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_status)<>0 THEN
58033: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS, 'FAIL TO SEND MESSAGE');
58034: END IF;
58035:
58036: END LAUNCH_WORKER;

Line 58552: DBMS_PIPE.PURGE( v_pipe_task_que);

58548: prec.kpi_bis_flag:=SYS_YES;
58549: END IF;
58550:
58551: --- Purge the existing pipes so that new pipes would be created
58552: DBMS_PIPE.PURGE( v_pipe_task_que);
58553: DBMS_PIPE.PURGE( v_pipe_wm);
58554: DBMS_PIPE.PURGE( v_pipe_mw);
58555: DBMS_PIPE.PURGE( v_pipe_status);
58556:

Line 58553: DBMS_PIPE.PURGE( v_pipe_wm);

58549: END IF;
58550:
58551: --- Purge the existing pipes so that new pipes would be created
58552: DBMS_PIPE.PURGE( v_pipe_task_que);
58553: DBMS_PIPE.PURGE( v_pipe_wm);
58554: DBMS_PIPE.PURGE( v_pipe_mw);
58555: DBMS_PIPE.PURGE( v_pipe_status);
58556:
58557: -- ============ Lauch the Workers here ===============

Line 58554: DBMS_PIPE.PURGE( v_pipe_mw);

58550:
58551: --- Purge the existing pipes so that new pipes would be created
58552: DBMS_PIPE.PURGE( v_pipe_task_que);
58553: DBMS_PIPE.PURGE( v_pipe_wm);
58554: DBMS_PIPE.PURGE( v_pipe_mw);
58555: DBMS_PIPE.PURGE( v_pipe_status);
58556:
58557: -- ============ Lauch the Workers here ===============
58558:

Line 58555: DBMS_PIPE.PURGE( v_pipe_status);

58551: --- Purge the existing pipes so that new pipes would be created
58552: DBMS_PIPE.PURGE( v_pipe_task_que);
58553: DBMS_PIPE.PURGE( v_pipe_wm);
58554: DBMS_PIPE.PURGE( v_pipe_mw);
58555: DBMS_PIPE.PURGE( v_pipe_status);
58556:
58557: -- ============ Lauch the Workers here ===============
58558:
58559: lvs_request_id.EXTEND( p_total_worker_num);

Line 58631: DBMS_PIPE.PACK_MESSAGE( '-1');

58627: END IF;
58628:
58629: FOR lc_i IN 1..p_total_worker_num LOOP
58630:
58631: DBMS_PIPE.PACK_MESSAGE( '-1');
58632:
58633: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58634: RAISE EX_PIPE_SND;
58635: END IF;

Line 58633: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58629: FOR lc_i IN 1..p_total_worker_num LOOP
58630:
58631: DBMS_PIPE.PACK_MESSAGE( '-1');
58632:
58633: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58634: RAISE EX_PIPE_SND;
58635: END IF;
58636:
58637: END LOOP;

Line 58668: DBMS_PIPE.PACK_MESSAGE(lv_message );

58664:
58665: -- ============ Send Tasks to Task Que 'v_pipe_task_que' =============
58666:
58667: lv_message := to_char(TASK_BIS_PERIODS);
58668: DBMS_PIPE.PACK_MESSAGE(lv_message );
58669: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58670: RAISE EX_PIPE_SND;
58671: END IF;
58672: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_BIS_PERIODS: '||lv_message);

Line 58669: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58665: -- ============ Send Tasks to Task Que 'v_pipe_task_que' =============
58666:
58667: lv_message := to_char(TASK_BIS_PERIODS);
58668: DBMS_PIPE.PACK_MESSAGE(lv_message );
58669: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58670: RAISE EX_PIPE_SND;
58671: END IF;
58672: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_BIS_PERIODS: '||lv_message);
58673: lv_task_not_completed := lv_task_not_completed + 1;

Line 58726: DBMS_PIPE.PACK_MESSAGE(lv_message );

58722: -- send out the batches to the workers' task Pipe
58723:
58724: FOR j in lv_batch_start..lv_batch_last LOOP
58725: lv_message := to_char(TASK_ITEM)||','||to_char(j);
58726: DBMS_PIPE.PACK_MESSAGE(lv_message );
58727: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58728: RAISE EX_PIPE_SND;
58729: END IF;
58730: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);

Line 58727: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58723:
58724: FOR j in lv_batch_start..lv_batch_last LOOP
58725: lv_message := to_char(TASK_ITEM)||','||to_char(j);
58726: DBMS_PIPE.PACK_MESSAGE(lv_message );
58727: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58728: RAISE EX_PIPE_SND;
58729: END IF;
58730: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);
58731: lv_total_item_batches := lv_total_item_batches + 1;

Line 58737: DBMS_PIPE.PACK_MESSAGE(lv_message );

58733: END LOOP;
58734:
58735: ELSE
58736: lv_message := to_char(TASK_ITEM)||','||to_char(0);
58737: DBMS_PIPE.PACK_MESSAGE(lv_message );
58738: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58739: RAISE EX_PIPE_SND;
58740: END IF;
58741: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);

Line 58738: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58734:
58735: ELSE
58736: lv_message := to_char(TASK_ITEM)||','||to_char(0);
58737: DBMS_PIPE.PACK_MESSAGE(lv_message );
58738: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58739: RAISE EX_PIPE_SND;
58740: END IF;
58741: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);
58742: lv_total_item_batches := lv_total_item_batches + 1;

Line 58753: DBMS_PIPE.PACK_MESSAGE(lv_message );

58749: EXCEPTION
58750: when others then
58751: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Error in Item Batch ID generation: ' || SQLERRM);
58752: lv_message := to_char(TASK_ITEM)||','||to_char(0);
58753: DBMS_PIPE.PACK_MESSAGE(lv_message );
58754: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58755: RAISE EX_PIPE_SND;
58756: END IF;
58757: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);

Line 58754: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58750: when others then
58751: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Error in Item Batch ID generation: ' || SQLERRM);
58752: lv_message := to_char(TASK_ITEM)||','||to_char(0);
58753: DBMS_PIPE.PACK_MESSAGE(lv_message );
58754: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58755: RAISE EX_PIPE_SND;
58756: END IF;
58757: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);
58758: lv_total_item_batches := lv_total_item_batches + 1;

Line 58769: DBMS_PIPE.PACK_MESSAGE(lv_message );

58765: -- kludge to launch the dependent tasks even if
58766: -- item is not enabled for processing
58767:
58768: lv_message := to_char(TASK_ITEM)||','||to_char(0);
58769: DBMS_PIPE.PACK_MESSAGE(lv_message );
58770: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58771: RAISE EX_PIPE_SND;
58772: END IF;
58773: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);

Line 58770: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58766: -- item is not enabled for processing
58767:
58768: lv_message := to_char(TASK_ITEM)||','||to_char(0);
58769: DBMS_PIPE.PACK_MESSAGE(lv_message );
58770: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58771: RAISE EX_PIPE_SND;
58772: END IF;
58773: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM: '||lv_message);
58774: lv_total_item_batches := lv_total_item_batches + 1;

Line 58786: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);

58782: EXIT WHEN is_request_status_running <> SYS_YES;
58783:
58784: EXIT WHEN is_worker_status_valid(lvs_request_id) <> SYS_YES;
58785:
58786: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
58787:
58788: IF lv_pipe_ret_code=0 THEN
58789: IF DBMS_PIPE.next_item_type <> 0 then
58790:

Line 58789: IF DBMS_PIPE.next_item_type <> 0 then

58785:
58786: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_wm, PIPE_TIME_OUT);
58787:
58788: IF lv_pipe_ret_code=0 THEN
58789: IF DBMS_PIPE.next_item_type <> 0 then
58790:
58791: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number );
58792:
58793: IF lv_task_number>0 THEN -- If it's ok, the value is the task number

Line 58791: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number );

58787:
58788: IF lv_pipe_ret_code=0 THEN
58789: IF DBMS_PIPE.next_item_type <> 0 then
58790:
58791: DBMS_PIPE.UNPACK_MESSAGE( lv_task_number );
58792:
58793: IF lv_task_number>0 THEN -- If it's ok, the value is the task number
58794: lv_task_not_completed := lv_task_not_completed -1;
58795:

Line 58812: DBMS_PIPE.PACK_MESSAGE(lv_message);

58808: END IF;
58809:
58810: IF p_comp_users_enabled = SYS_YES AND v_MSC_CONFIGURATION IN(2,3) THEN
58811: lv_message := to_char(TASK_COMPANY_USERS);
58812: DBMS_PIPE.PACK_MESSAGE(lv_message);
58813: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58814: RAISE EX_PIPE_SND;
58815: END IF;
58816: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_COMPANY_USERS: '||lv_message);

Line 58813: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58809:
58810: IF p_comp_users_enabled = SYS_YES AND v_MSC_CONFIGURATION IN(2,3) THEN
58811: lv_message := to_char(TASK_COMPANY_USERS);
58812: DBMS_PIPE.PACK_MESSAGE(lv_message);
58813: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58814: RAISE EX_PIPE_SND;
58815: END IF;
58816: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_COMPANY_USERS: '||lv_message);
58817: lv_task_not_completed := lv_task_not_completed + 1;

Line 58822: DBMS_PIPE.PACK_MESSAGE(lv_message);

58818: END IF;
58819:
58820: IF p_uom_class_enabled = SYS_YES THEN
58821: lv_message := to_char(TASK_UOM_CONV);
58822: DBMS_PIPE.PACK_MESSAGE(lv_message);
58823: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58824: RAISE EX_PIPE_SND;
58825: END IF;
58826: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_UOM_CONV: '||lv_message);

Line 58823: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58819:
58820: IF p_uom_class_enabled = SYS_YES THEN
58821: lv_message := to_char(TASK_UOM_CONV);
58822: DBMS_PIPE.PACK_MESSAGE(lv_message);
58823: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58824: RAISE EX_PIPE_SND;
58825: END IF;
58826: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_UOM_CONV: '||lv_message);
58827: lv_task_not_completed := lv_task_not_completed + 1;

Line 58832: DBMS_PIPE.PACK_MESSAGE(lv_message);

58828: END IF;
58829:
58830: IF p_item_cst_enabled = SYS_YES AND v_sce_installed THEN
58831: lv_message := to_char(TASK_ITEM_CST);
58832: DBMS_PIPE.PACK_MESSAGE(lv_message);
58833: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58834: RAISE EX_PIPE_SND;
58835: END IF;
58836: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM_CST: '||lv_message);

Line 58833: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58829:
58830: IF p_item_cst_enabled = SYS_YES AND v_sce_installed THEN
58831: lv_message := to_char(TASK_ITEM_CST);
58832: DBMS_PIPE.PACK_MESSAGE(lv_message);
58833: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58834: RAISE EX_PIPE_SND;
58835: END IF;
58836: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM_CST: '||lv_message);
58837: lv_task_not_completed := lv_task_not_completed + 1;

Line 58842: DBMS_PIPE.PACK_MESSAGE(lv_message);

58838: END IF;
58839:
58840:
58841: lv_message := to_char(TASK_SUPPLIER_CAPACITY);
58842: DBMS_PIPE.PACK_MESSAGE(lv_message);
58843: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58844: RAISE EX_PIPE_SND;
58845: END IF;
58846: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SUPPLIER_CAPACITY: '||lv_message);

Line 58843: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58839:
58840:
58841: lv_message := to_char(TASK_SUPPLIER_CAPACITY);
58842: DBMS_PIPE.PACK_MESSAGE(lv_message);
58843: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58844: RAISE EX_PIPE_SND;
58845: END IF;
58846: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SUPPLIER_CAPACITY: '||lv_message);
58847: lv_task_not_completed := lv_task_not_completed + 1;

Line 58850: DBMS_PIPE.PACK_MESSAGE(lv_message);

58846: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SUPPLIER_CAPACITY: '||lv_message);
58847: lv_task_not_completed := lv_task_not_completed + 1;
58848:
58849: lv_message := to_char(TASK_CAL_ASSIGNMENTS);
58850: DBMS_PIPE.PACK_MESSAGE(lv_message);
58851: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58852: RAISE EX_PIPE_SND;
58853: END IF;
58854: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CAL_ASSIGNMENTS: '||lv_message);

Line 58851: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58847: lv_task_not_completed := lv_task_not_completed + 1;
58848:
58849: lv_message := to_char(TASK_CAL_ASSIGNMENTS);
58850: DBMS_PIPE.PACK_MESSAGE(lv_message);
58851: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58852: RAISE EX_PIPE_SND;
58853: END IF;
58854: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CAL_ASSIGNMENTS: '||lv_message);
58855: lv_task_not_completed := lv_task_not_completed + 1;

Line 58858: DBMS_PIPE.PACK_MESSAGE(lv_message);

58854: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CAL_ASSIGNMENTS: '||lv_message);
58855: lv_task_not_completed := lv_task_not_completed + 1;
58856:
58857: lv_message := to_char(TASK_SALES_CHANNEL);
58858: DBMS_PIPE.PACK_MESSAGE(lv_message);
58859: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58860: RAISE EX_PIPE_SND;
58861: END IF;
58862: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SALES_CHANNEL: '||lv_message);

Line 58859: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58855: lv_task_not_completed := lv_task_not_completed + 1;
58856:
58857: lv_message := to_char(TASK_SALES_CHANNEL);
58858: DBMS_PIPE.PACK_MESSAGE(lv_message);
58859: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58860: RAISE EX_PIPE_SND;
58861: END IF;
58862: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SALES_CHANNEL: '||lv_message);
58863: lv_task_not_completed := lv_task_not_completed + 1;

Line 58866: DBMS_PIPE.PACK_MESSAGE(lv_message);

58862: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SALES_CHANNEL: '||lv_message);
58863: lv_task_not_completed := lv_task_not_completed + 1;
58864:
58865: lv_message := to_char(TASK_FISCAL_CALENDAR);
58866: DBMS_PIPE.PACK_MESSAGE(lv_message);
58867: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58868: RAISE EX_PIPE_SND;
58869: END IF;
58870: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_FISCAL_CALENDAR: '||lv_message);

Line 58867: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58863: lv_task_not_completed := lv_task_not_completed + 1;
58864:
58865: lv_message := to_char(TASK_FISCAL_CALENDAR);
58866: DBMS_PIPE.PACK_MESSAGE(lv_message);
58867: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58868: RAISE EX_PIPE_SND;
58869: END IF;
58870: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_FISCAL_CALENDAR: '||lv_message);
58871: lv_task_not_completed := lv_task_not_completed + 1;

Line 58874: DBMS_PIPE.PACK_MESSAGE(lv_message);

58870: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_FISCAL_CALENDAR: '||lv_message);
58871: lv_task_not_completed := lv_task_not_completed + 1;
58872:
58873: lv_message := to_char(TASK_CMRO);
58874: DBMS_PIPE.PACK_MESSAGE(lv_message);
58875: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58876: RAISE EX_PIPE_SND;
58877: END IF;
58878: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CMRO: '||lv_message);

Line 58875: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58871: lv_task_not_completed := lv_task_not_completed + 1;
58872:
58873: lv_message := to_char(TASK_CMRO);
58874: DBMS_PIPE.PACK_MESSAGE(lv_message);
58875: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58876: RAISE EX_PIPE_SND;
58877: END IF;
58878: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CMRO: '||lv_message);
58879: lv_task_not_completed := lv_task_not_completed + 1;

Line 58884: DBMS_PIPE.PACK_MESSAGE(lv_message);

58880:
58881:
58882:
58883: lv_message := to_char(TASK_SAFETY_STOCK);
58884: DBMS_PIPE.PACK_MESSAGE(lv_message);
58885: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58886: RAISE EX_PIPE_SND;
58887: END IF;
58888: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SAFETY_STOCK: '||lv_message);

Line 58885: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58881:
58882:
58883: lv_message := to_char(TASK_SAFETY_STOCK);
58884: DBMS_PIPE.PACK_MESSAGE(lv_message);
58885: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58886: RAISE EX_PIPE_SND;
58887: END IF;
58888: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SAFETY_STOCK: '||lv_message);
58889: lv_task_not_completed := lv_task_not_completed + 1;

Line 58893: DBMS_PIPE.PACK_MESSAGE(lv_message);

58889: lv_task_not_completed := lv_task_not_completed + 1;
58890:
58891:
58892: lv_message := to_char(TASK_CATEGORIES_SOURCING);
58893: DBMS_PIPE.PACK_MESSAGE(lv_message);
58894: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58895: RAISE EX_PIPE_SND;
58896: END IF;
58897: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CATEGORIES_SOURCING: '||lv_message);

Line 58894: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58890:
58891:
58892: lv_message := to_char(TASK_CATEGORIES_SOURCING);
58893: DBMS_PIPE.PACK_MESSAGE(lv_message);
58894: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58895: RAISE EX_PIPE_SND;
58896: END IF;
58897: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CATEGORIES_SOURCING: '||lv_message);
58898: lv_task_not_completed := lv_task_not_completed + 1;

Line 58901: DBMS_PIPE.PACK_MESSAGE(lv_message);

58897: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_CATEGORIES_SOURCING: '||lv_message);
58898: lv_task_not_completed := lv_task_not_completed + 1;
58899:
58900: lv_message := to_char(TASK_DEPT_RESOURCES);
58901: DBMS_PIPE.PACK_MESSAGE(lv_message);
58902: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58903: RAISE EX_PIPE_SND;
58904: END IF;
58905: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_DEPT_RESOURCES: '||lv_message);

Line 58902: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58898: lv_task_not_completed := lv_task_not_completed + 1;
58899:
58900: lv_message := to_char(TASK_DEPT_RESOURCES);
58901: DBMS_PIPE.PACK_MESSAGE(lv_message);
58902: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58903: RAISE EX_PIPE_SND;
58904: END IF;
58905: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_DEPT_RESOURCES: '||lv_message);
58906: lv_task_not_completed := lv_task_not_completed + 1;

Line 58909: DBMS_PIPE.PACK_MESSAGE(lv_message);

58905: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_DEPT_RESOURCES: '||lv_message);
58906: lv_task_not_completed := lv_task_not_completed + 1;
58907:
58908: lv_message := to_char(TASK_ITEM_SUBSTITUTE);
58909: DBMS_PIPE.PACK_MESSAGE(lv_message);
58910: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58911: RAISE EX_PIPE_SND;
58912: END IF;
58913: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM_SUBSTITUTE: '||lv_message);

Line 58910: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58906: lv_task_not_completed := lv_task_not_completed + 1;
58907:
58908: lv_message := to_char(TASK_ITEM_SUBSTITUTE);
58909: DBMS_PIPE.PACK_MESSAGE(lv_message);
58910: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58911: RAISE EX_PIPE_SND;
58912: END IF;
58913: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ITEM_SUBSTITUTE: '||lv_message);
58914: lv_task_not_completed := lv_task_not_completed + 1;

Line 58919: DBMS_PIPE.PACK_MESSAGE(lv_message);

58915:
58916:
58917: IF p_fiscal_cal_enabled = SYS_YES THEN
58918: lv_message := to_char(TASK_FISCAL_TIME);
58919: DBMS_PIPE.PACK_MESSAGE(lv_message);
58920: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58921: RAISE EX_PIPE_SND;
58922: END IF;
58923: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_FISCAL_TIME: '||lv_message);

Line 58920: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58916:
58917: IF p_fiscal_cal_enabled = SYS_YES THEN
58918: lv_message := to_char(TASK_FISCAL_TIME);
58919: DBMS_PIPE.PACK_MESSAGE(lv_message);
58920: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58921: RAISE EX_PIPE_SND;
58922: END IF;
58923: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_FISCAL_TIME: '||lv_message);
58924: lv_task_not_completed := lv_task_not_completed + 1;

Line 58930: DBMS_PIPE.PACK_MESSAGE(lv_message);

58926:
58927:
58928: IF p_comp_cal_enabled = SYS_YES THEN
58929: lv_message := to_char(TASK_COMPOSITE_TIME);
58930: DBMS_PIPE.PACK_MESSAGE(lv_message);
58931: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58932: RAISE EX_PIPE_SND;
58933: END IF;
58934: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_COMPOSITE_TIME: '||lv_message);

Line 58931: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58927:
58928: IF p_comp_cal_enabled = SYS_YES THEN
58929: lv_message := to_char(TASK_COMPOSITE_TIME);
58930: DBMS_PIPE.PACK_MESSAGE(lv_message);
58931: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58932: RAISE EX_PIPE_SND;
58933: END IF;
58934: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_COMPOSITE_TIME: '||lv_message);
58935: lv_task_not_completed := lv_task_not_completed + 1;

Line 58990: DBMS_PIPE.PACK_MESSAGE(lv_message);

58986: -- send out the batches to the workers' task Pipe
58987:
58988: FOR j in lv_batch_start..lv_batch_last LOOP
58989: lv_message := to_char(TASK_MATERIAL_SUPPLY)||','||to_char(j);
58990: DBMS_PIPE.PACK_MESSAGE(lv_message);
58991: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58992: RAISE EX_PIPE_SND;
58993: END IF;
58994: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_MATERIAL_SUPPLY: '||lv_message);

Line 58991: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

58987:
58988: FOR j in lv_batch_start..lv_batch_last LOOP
58989: lv_message := to_char(TASK_MATERIAL_SUPPLY)||','||to_char(j);
58990: DBMS_PIPE.PACK_MESSAGE(lv_message);
58991: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
58992: RAISE EX_PIPE_SND;
58993: END IF;
58994: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_MATERIAL_SUPPLY: '||lv_message);
58995: lv_total_supply_batches := lv_total_supply_batches + 1;

Line 59065: DBMS_PIPE.PACK_MESSAGE(lv_message);

59061: -- send out the batches to the workers' task Pipe
59062:
59063: FOR j in lv_batch_start..lv_batch_last LOOP
59064: lv_message := to_char(TASK_MATERIAL_DEMAND)||','||to_char(j);
59065: DBMS_PIPE.PACK_MESSAGE(lv_message);
59066: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59067: RAISE EX_PIPE_SND;
59068: END IF;
59069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_MATERIAL_DEMAND: '||lv_message);

Line 59066: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59062:
59063: FOR j in lv_batch_start..lv_batch_last LOOP
59064: lv_message := to_char(TASK_MATERIAL_DEMAND)||','||to_char(j);
59065: DBMS_PIPE.PACK_MESSAGE(lv_message);
59066: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59067: RAISE EX_PIPE_SND;
59068: END IF;
59069: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_MATERIAL_DEMAND: '||lv_message);
59070: lv_total_demand_batches := lv_total_demand_batches + 1;

Line 59147: DBMS_PIPE.PACK_MESSAGE(lv_message);

59143: -- send out the batches to the workers' task Pipe
59144:
59145: FOR j in lv_batch_start..lv_batch_last LOOP
59146: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(j);
59147: DBMS_PIPE.PACK_MESSAGE(lv_message);
59148: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59149: RAISE EX_PIPE_SND;
59150: END IF;
59151: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);

Line 59148: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59144:
59145: FOR j in lv_batch_start..lv_batch_last LOOP
59146: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(j);
59147: DBMS_PIPE.PACK_MESSAGE(lv_message);
59148: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59149: RAISE EX_PIPE_SND;
59150: END IF;
59151: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);
59152: lv_total_demand_batches := lv_total_demand_batches + 1;

Line 59159: DBMS_PIPE.PACK_MESSAGE(lv_message );

59155:
59156: CREATE_INDEXES('SO');
59157: ELSE
59158: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(0);
59159: DBMS_PIPE.PACK_MESSAGE(lv_message );
59160: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59161: RAISE EX_PIPE_SND;
59162: END IF;
59163: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);

Line 59160: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59156: CREATE_INDEXES('SO');
59157: ELSE
59158: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(0);
59159: DBMS_PIPE.PACK_MESSAGE(lv_message );
59160: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59161: RAISE EX_PIPE_SND;
59162: END IF;
59163: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);
59164: lv_total_demand_batches := lv_total_demand_batches + 1;

Line 59173: DBMS_PIPE.PACK_MESSAGE(lv_message );

59169: EXCEPTION
59170: when others then
59171: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Error in Sales Order Demands Batch ID generation: ' || SQLERRM);
59172: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(0);
59173: DBMS_PIPE.PACK_MESSAGE(lv_message );
59174: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59175: RAISE EX_PIPE_SND;
59176: END IF;
59177: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);

Line 59174: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59170: when others then
59171: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Error in Sales Order Demands Batch ID generation: ' || SQLERRM);
59172: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(0);
59173: DBMS_PIPE.PACK_MESSAGE(lv_message );
59174: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59175: RAISE EX_PIPE_SND;
59176: END IF;
59177: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);
59178: lv_total_demand_batches := lv_total_demand_batches + 1;

Line 59190: DBMS_PIPE.PACK_MESSAGE(lv_message );

59186: -- kludge to launch the dependent tasks even if
59187: -- demand is not enabled for processing
59188:
59189: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(0);
59190: DBMS_PIPE.PACK_MESSAGE(lv_message );
59191: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59192: RAISE EX_PIPE_SND;
59193: END IF;
59194: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);

Line 59191: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59187: -- demand is not enabled for processing
59188:
59189: lv_message := to_char(TASK_SO_DEMAND)||','||to_char(0);
59190: DBMS_PIPE.PACK_MESSAGE(lv_message );
59191: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59192: RAISE EX_PIPE_SND;
59193: END IF;
59194: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);
59195: lv_total_demand_batches := lv_total_demand_batches + 1;

Line 59207: DBMS_PIPE.PACK_MESSAGE(lv_message);

59203:
59204: IF lv_demand_batches_completed = lv_total_demand_batches THEN
59205:
59206: lv_message := to_char(TASK_RESERVATION);
59207: DBMS_PIPE.PACK_MESSAGE(lv_message);
59208: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59209: RAISE EX_PIPE_SND;
59210: END IF;
59211: LOG_MESSAGE('TASK_RESERVATION: '||lv_message);

Line 59208: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59204: IF lv_demand_batches_completed = lv_total_demand_batches THEN
59205:
59206: lv_message := to_char(TASK_RESERVATION);
59207: DBMS_PIPE.PACK_MESSAGE(lv_message);
59208: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59209: RAISE EX_PIPE_SND;
59210: END IF;
59211: LOG_MESSAGE('TASK_RESERVATION: '||lv_message);
59212:

Line 59220: DBMS_PIPE.PACK_MESSAGE(lv_message);

59216:
59217: ELSIF lv_task_number= TASK_DEPT_RESOURCES THEN
59218:
59219: lv_message := to_char(TASK_BOM_ROUTING);
59220: DBMS_PIPE.PACK_MESSAGE(lv_message);
59221: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59222: RAISE EX_PIPE_SND;
59223: END IF;
59224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_BOM_ROUTING: '||lv_message);

Line 59221: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59217: ELSIF lv_task_number= TASK_DEPT_RESOURCES THEN
59218:
59219: lv_message := to_char(TASK_BOM_ROUTING);
59220: DBMS_PIPE.PACK_MESSAGE(lv_message);
59221: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59222: RAISE EX_PIPE_SND;
59223: END IF;
59224: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_BOM_ROUTING: '||lv_message);
59225:

Line 59233: DBMS_PIPE.PACK_MESSAGE(lv_message);

59229:
59230: ELSIF lv_task_number= TASK_BOM_ROUTING THEN
59231:
59232: lv_message := to_char(TASK_RESOURCE_DEMAND);
59233: DBMS_PIPE.PACK_MESSAGE(lv_message);
59234: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59235: RAISE EX_PIPE_SND;
59236: END IF;
59237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_RESOURCE_DEMAND: '||lv_message);

Line 59234: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59230: ELSIF lv_task_number= TASK_BOM_ROUTING THEN
59231:
59232: lv_message := to_char(TASK_RESOURCE_DEMAND);
59233: DBMS_PIPE.PACK_MESSAGE(lv_message);
59234: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59235: RAISE EX_PIPE_SND;
59236: END IF;
59237: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_RESOURCE_DEMAND: '||lv_message);
59238:

Line 59242: DBMS_PIPE.PACK_MESSAGE(lv_message);

59238:
59239: lv_task_not_completed := lv_task_not_completed + 1;
59240:
59241: lv_message := to_char(TASK_IRO);
59242: DBMS_PIPE.PACK_MESSAGE(lv_message);
59243: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59244: RAISE EX_PIPE_SND;
59245: END IF;
59246:

Line 59243: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59239: lv_task_not_completed := lv_task_not_completed + 1;
59240:
59241: lv_message := to_char(TASK_IRO);
59242: DBMS_PIPE.PACK_MESSAGE(lv_message);
59243: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59244: RAISE EX_PIPE_SND;
59245: END IF;
59246:
59247: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_IRO: '||lv_message);

Line 59251: DBMS_PIPE.PACK_MESSAGE(lv_message);

59247: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_IRO: '||lv_message);
59248: lv_task_not_completed := lv_task_not_completed + 1;
59249:
59250: lv_message := to_char(TASK_ERO);
59251: DBMS_PIPE.PACK_MESSAGE(lv_message);
59252: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59253: RAISE EX_PIPE_SND;
59254: END IF;
59255: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ERO: '||lv_message);

Line 59252: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59248: lv_task_not_completed := lv_task_not_completed + 1;
59249:
59250: lv_message := to_char(TASK_ERO);
59251: DBMS_PIPE.PACK_MESSAGE(lv_message);
59252: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59253: RAISE EX_PIPE_SND;
59254: END IF;
59255: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_ERO: '||lv_message);
59256: lv_task_not_completed := lv_task_not_completed + 1;

Line 59315: DBMS_PIPE.PACK_MESSAGE(lv_message);

59311: -- send out the batches to the workers' task Pipe
59312:
59313: FOR j in lv_batch_start..lv_batch_last LOOP
59314: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(j);
59315: DBMS_PIPE.PACK_MESSAGE(lv_message);
59316: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59317: RAISE EX_PIPE_SND;
59318: END IF;
59319: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);

Line 59316: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59312:
59313: FOR j in lv_batch_start..lv_batch_last LOOP
59314: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(j);
59315: DBMS_PIPE.PACK_MESSAGE(lv_message);
59316: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59317: RAISE EX_PIPE_SND;
59318: END IF;
59319: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_SO_DEMAND: '||lv_message);
59320: lv_total_lvalue_batches := lv_total_lvalue_batches + 1;

Line 59326: DBMS_PIPE.PACK_MESSAGE(lv_message );

59322: END LOOP;
59323: -- CREATE_INDEXES('LEVEL_VALUE');
59324: ELSE
59325: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(0);
59326: DBMS_PIPE.PACK_MESSAGE(lv_message );
59327: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59328: RAISE EX_PIPE_SND;
59329: END IF;
59330: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_LEVEL_VALUE: '||lv_message);

Line 59327: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59323: -- CREATE_INDEXES('LEVEL_VALUE');
59324: ELSE
59325: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(0);
59326: DBMS_PIPE.PACK_MESSAGE(lv_message );
59327: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59328: RAISE EX_PIPE_SND;
59329: END IF;
59330: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_LEVEL_VALUE: '||lv_message);
59331: lv_total_lvalue_batches := lv_total_lvalue_batches + 1;

Line 59341: DBMS_PIPE.PACK_MESSAGE(lv_message );

59337: EXCEPTION
59338: when others then
59339: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Error in Batch ID generation: ' || SQLERRM);
59340: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(0);
59341: DBMS_PIPE.PACK_MESSAGE(lv_message );
59342: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59343: RAISE EX_PIPE_SND;
59344: END IF;
59345: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_LEVEL_VALUE: '||lv_message);

Line 59342: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59338: when others then
59339: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'Error in Batch ID generation: ' || SQLERRM);
59340: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(0);
59341: DBMS_PIPE.PACK_MESSAGE(lv_message );
59342: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59343: RAISE EX_PIPE_SND;
59344: END IF;
59345: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_LEVEL_VALUE: '||lv_message);
59346: lv_total_lvalue_batches := lv_total_lvalue_batches + 1;

Line 59357: DBMS_PIPE.PACK_MESSAGE(lv_message );

59353: -- kludge to launch the dependent tasks even if
59354: -- level_value is not enabled for processing
59355:
59356: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(0);
59357: DBMS_PIPE.PACK_MESSAGE(lv_message );
59358: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59359: RAISE EX_PIPE_SND;
59360: END IF;
59361: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_LEVEL_VALUE: '||lv_message);

Line 59358: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59354: -- level_value is not enabled for processing
59355:
59356: lv_message := to_char(TASK_LEVEL_VALUE)||','||to_char(0);
59357: DBMS_PIPE.PACK_MESSAGE(lv_message );
59358: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59359: RAISE EX_PIPE_SND;
59360: END IF;
59361: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'TASK_LEVEL_VALUE: '||lv_message);
59362: lv_total_lvalue_batches := lv_total_lvalue_batches + 1;

Line 59486: DBMS_PIPE.PACK_MESSAGE(lv_message); -- resend the task to the task que

59482: /* not required since worker always send unresolvable errors
59483: ** even if we enable this how do we get the batch id ?
59484: EXIT WHEN lv_task_number= UNRESOVLABLE_ERROR;
59485: lv_message := to_char (-lv_task_number);
59486: DBMS_PIPE.PACK_MESSAGE(lv_message); -- resend the task to the task que
59487: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59488: RAISE EX_PIPE_SND;
59489: END IF;
59490: */

Line 59487: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59483: ** even if we enable this how do we get the batch id ?
59484: EXIT WHEN lv_task_number= UNRESOVLABLE_ERROR;
59485: lv_message := to_char (-lv_task_number);
59486: DBMS_PIPE.PACK_MESSAGE(lv_message); -- resend the task to the task que
59487: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59488: RAISE EX_PIPE_SND;
59489: END IF;
59490: */
59491:

Line 59494: END IF; -- DBMS_PIPE.next_item_type <> 0

59490: */
59491:
59492: END IF; -- lv_task_number > 0
59493:
59494: END IF; -- DBMS_PIPE.next_item_type <> 0
59495:
59496: ELSIF lv_pipe_ret_code <> 1 THEN -- not time out, either 2 (record too big for buffer) or 3 (interuppted)
59497:
59498: RAISE EX_PIPE_RCV;

Line 59518: DBMS_PIPE.PURGE( v_pipe_task_que);

59514: end if ;
59515:
59516: IF lv_task_not_completed > 0 THEN
59517:
59518: DBMS_PIPE.PURGE( v_pipe_task_que);
59519:
59520: lv_task_number:= -1;
59521:
59522: ROLLBACK;

Line 59555: DBMS_PIPE.PACK_MESSAGE( lv_message);

59551:
59552: FOR lc_i IN 1..p_total_worker_num LOOP
59553:
59554: lv_message := to_char(lv_task_number);
59555: DBMS_PIPE.PACK_MESSAGE( lv_message);
59556: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59557: RAISE EX_PIPE_SND;
59558: END IF;
59559: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'v_pipe_task_que: '||lv_message);

Line 59556: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN

59552: FOR lc_i IN 1..p_total_worker_num LOOP
59553:
59554: lv_message := to_char(lv_task_number);
59555: DBMS_PIPE.PACK_MESSAGE( lv_message);
59556: IF DBMS_PIPE.SEND_MESSAGE( v_pipe_task_que)<>0 THEN
59557: RAISE EX_PIPE_SND;
59558: END IF;
59559: MSC_UTIL.LOG_MSG(MSC_UTIL.G_LVL_STATUS,'v_pipe_task_que: '||lv_message);
59560:

Line 59569: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status, PIPE_TIME_OUT);

59565: lv_start_time:= SYSDATE;
59566:
59567: LOOP
59568:
59569: lv_pipe_ret_code:= DBMS_PIPE.RECEIVE_MESSAGE( v_pipe_status, PIPE_TIME_OUT);
59570:
59571: IF lv_pipe_ret_code=0 THEN
59572:
59573: lv_worker_committed:= lv_worker_committed+1;