유량제어 FIX, 표준전문 FIX

src/main/java/com/eactive/eai/common/inflow/InflowControlManager.java

@@ -67,11 +67,9 @@ public class InflowControlManager implements Lifecycle, Bucket {
 	 */
 	public static Boolean isTargetOfInflowControl(EAIServerManager eaiServerManager, EAIMessage eaiMessage) {
 		InterfaceMapper mapper = eaiMessage.getMapper();
-		String inExDiv = MessageUtil.getInExDivision(mapper.getInExDivision(eaiMessage.getStandardMessage()),
-				eaiMessage.getInternalExternalDvcd()); // 1|2
 		String returnType = mapper.getSendRecvDivision(eaiMessage.getStandardMessage()); // S|R
 
-		if (STDMessageKeys.DIRECTION_IN.equals(inExDiv) && STDMessageKeys.SEND_RECV_CD_SEND.equals(returnType)) {
+		if (STDMessageKeys.SEND_RECV_CD_SEND.equals(returnType)) {
 			return Boolean.valueOf(true);
 		}
 

src/main/java/com/eactive/eai/inbound/processor/RequestProcessor.java

@@ -1036,6 +1036,7 @@ public class RequestProcessor extends RequestProcessorSupport {
 				}
 			}
 
+			String inflowErrorMsg;
 			if (blockedType.length() > 0) {
 				InflowTargetVO inflowTargetVO = null;
 				InflowGroupVO inflowGroupVO = null;
@@ -1046,7 +1047,6 @@ public class RequestProcessor extends RequestProcessorSupport {
 				} else {
 					inflowTargetVO = bucket.getInterfaceInflowThreashold(vo.getEaiSvcCd());
 				}
-				String inflowErrorMsg;
 				// 에러처리
 				vo.setRspErrorCode(EAIMessageKeys.EAI_INFLOW_BLOCKED_CODE);
 				if (inflowGroupVO != null) {
@@ -1161,7 +1161,8 @@ public class RequestProcessor extends RequestProcessorSupport {
 						if (logger.isError())
 							logger.error(guidLogPrefix + " : 유량제어 비동기 에러응답송신 실패  - " + ee.toString());
 					}
-					return null;
+					throw new HttpStatusException(eaiMsg.getRspErrMsg(), eaiMsg.getRspErrCd(),
+							HttpStatus.TOO_MANY_REQUESTS.value());
 				}
 			}
 		}
@@ -1273,7 +1274,7 @@ public class RequestProcessor extends RequestProcessorSupport {
 		}
 
 		//응답 전 표준 전문의 로직 처리 필요 한 경우를 위해 호출
-		standardManager.getMessageCoordinator().coordinateBeforeResponse(standardMessage, vo, prop, inboundCharset);
+		standardManager.getMessageCoordinator().coordinateBeforeResponse(retEaiMsg.getStandardMessage(), vo, prop, inboundCharset);
 		
 		// 10. 응답 거래로그 Logging
 		if(EAIMessageKeys.SYNC_SVC.equals(svcTsmtUsgTp) &&