From 940e5bb90c76e8498f839891f0b2cb2292a43ba9 Mon Sep 17 00:00:00 2001 From: curry772 Date: Wed, 10 Jun 2026 08:53:39 +0900 Subject: [PATCH] =?UTF-8?q?EAIMessage=EC=97=90=20callProp=EB=A5=BC=20?= =?UTF-8?q?=EC=B6=94=EA=B0=80=ED=95=98=EA=B3=A0,=20=EB=8F=99=EA=B8=B0=20?= =?UTF-8?q?=EA=B1=B0=EB=9E=98=EC=97=90=20=EB=8C=80=ED=95=9C=20Outbound?= =?UTF-8?q?=EC=97=90=EC=84=9C=20=EC=84=B8=ED=8C=85=ED=95=9C=20callProp?= =?UTF-8?q?=EA=B0=80=20RequestProcessor,=20EAIMessage=EB=A5=BC=20=ED=86=B5?= =?UTF-8?q?=ED=95=B4=20=EC=A0=91=EA=B7=BC=20=EA=B0=80=EB=8A=A5=ED=95=98?= =?UTF-8?q?=EB=8F=84=EB=A1=9D=20=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../eai/common/message/EAIMessage.java | 13 +++++++++++-- .../inbound/processor/RequestProcessor.java | 6 ++++-- .../eactive/eai/outbound/DefaultProcess.java | 19 ++++++++++--------- 3 files changed, 25 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/eactive/eai/common/message/EAIMessage.java b/src/main/java/com/eactive/eai/common/message/EAIMessage.java index b8345e0..127621f 100644 --- a/src/main/java/com/eactive/eai/common/message/EAIMessage.java +++ b/src/main/java/com/eactive/eai/common/message/EAIMessage.java @@ -1,11 +1,11 @@ package com.eactive.eai.common.message; import java.io.Serializable; -import java.nio.charset.Charset; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.Properties; import com.eactive.eai.message.StandardMessage; import com.eactive.eai.message.manager.StandardMessageManager; @@ -109,7 +109,8 @@ public class EAIMessage implements EAIMessageKeys, Serializable, Comparable(); @@ -664,6 +665,14 @@ public class EAIMessage implements EAIMessageKeys, Serializable, Comparable getTransactionContextTransfer() { return transactionContextTransfer; } + + public Properties getCallProp() { + return callProp; + } + + public void setCallProp(Properties callProp) { + this.callProp = callProp; + } /** * [비동기 전달 전용] 컨텍스트 전달용 Map 설정 diff --git a/src/main/java/com/eactive/eai/inbound/processor/RequestProcessor.java b/src/main/java/com/eactive/eai/inbound/processor/RequestProcessor.java index 9e63690..f72452a 100644 --- a/src/main/java/com/eactive/eai/inbound/processor/RequestProcessor.java +++ b/src/main/java/com/eactive/eai/inbound/processor/RequestProcessor.java @@ -464,7 +464,9 @@ public class RequestProcessor extends RequestProcessorSupport { logUnknownMessage(vo,orgMessage); return getInboundErrorResponse(prop, standardMessage, mapper, vo.getRspErrorCode(), vo.getRspErrorMsg(), inboundCharset); } - + + eaiMsg.setCallProp(prop); + // set standardMessage & mapper to EAIMessage eaiMsg.setStandardMessage(standardMessage); eaiMsg.setMapper(mapper); @@ -1256,7 +1258,7 @@ public class RequestProcessor extends RequestProcessorSupport { beforeRoute(eaiMsg, prop); retEaiMsg = FlowRouter.process(eaiMsg, prop); - + retEaiMsg.setCallProp(prop); // 응답메시지에 Error Code기 설정되어 있을 경우 // ExceptionHandler를 통해 응답메시지를 생성한다. if(retEaiMsg != null && !MessageUtil.checkRspErrCd(retEaiMsg.getRspErrCd())) { diff --git a/src/main/java/com/eactive/eai/outbound/DefaultProcess.java b/src/main/java/com/eactive/eai/outbound/DefaultProcess.java index 6786e1d..9bfa3fc 100644 --- a/src/main/java/com/eactive/eai/outbound/DefaultProcess.java +++ b/src/main/java/com/eactive/eai/outbound/DefaultProcess.java @@ -776,17 +776,18 @@ public abstract class DefaultProcess extends Process { if(this.tempProp.get(HttpAdapterServiceKey.OUTBOUND_PROPERTY_MAP) instanceof Map) { Map map = (Map) this.tempProp.get(HttpAdapterServiceKey.OUTBOUND_PROPERTY_MAP); this.resObject = map.get(HttpAdapterServiceKey.OUTBOUND_RESPONSE_MESSAGE); + this.callProp.put(HttpAdapterServiceKey.OUTBOUND_PROPERTY_MAP, map); } standardMessage.setBizData(this.resObject, this.inboundCharset); - try { - //mapper.nextGuidSeq(standardMessage); - mapper.setSendRecvDivision(standardMessage, STDMessageKeys.SEND_RECV_CD_RECV); - StandardMessageManager standardManager = StandardMessageManager.getInstance(); - standardManager.getMessageCoordinator().coordinateSetStandardMessageError(standardMessage, mapper, - this.resEaiMsg.getRspErrCd(), this.resEaiMsg.getRspErrMsg()); - } catch (Exception e) { - logger.error(e.getMessage()); - } +// try { +// //mapper.nextGuidSeq(standardMessage); +// mapper.setSendRecvDivision(standardMessage, STDMessageKeys.SEND_RECV_CD_RECV); +// StandardMessageManager standardManager = StandardMessageManager.getInstance(); +// standardManager.getMessageCoordinator().coordinateSetStandardMessageError(standardMessage, mapper, +// this.resEaiMsg.getRspErrCd(), this.resEaiMsg.getRspErrMsg()); +// } catch (Exception e) { +// logger.error(e.getMessage()); +// } } public boolean isRequest() {