From 52da4abb97963002ec40184393eb995e7d3e2208 Mon Sep 17 00:00:00 2001 From: cho Date: Wed, 28 Jan 2026 14:51:55 +0900 Subject: [PATCH] =?UTF-8?q?=EA=B3=84=EC=A0=95=EA=B3=84=20=EA=B3=B5?= =?UTF-8?q?=ED=86=B5=ED=8C=80=20=EC=9A=94=EC=B2=AD,=20=EC=9D=91=EB=8B=B5?= =?UTF-8?q?=20=ED=91=9C=EC=A4=80=EB=A9=94=EC=84=B8=EC=A7=80=EC=97=90=20?= =?UTF-8?q?=EB=A9=94=EC=84=B8=EC=A7=80=EB=B6=80=20=EC=A0=9C=EA=B1=B0.=20(A?= =?UTF-8?q?-S=20=EC=9D=91=EB=8B=B5=EC=9D=BC=EB=95=8C=EB=A7=8C)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../eactive/eai/outbound/SocketProcess.java | 25 +++++++++++++++++++ 1 file changed, 25 insertions(+) diff --git a/src/main/java/com/eactive/eai/outbound/SocketProcess.java b/src/main/java/com/eactive/eai/outbound/SocketProcess.java index d3912f7..e7e8d9b 100644 --- a/src/main/java/com/eactive/eai/outbound/SocketProcess.java +++ b/src/main/java/com/eactive/eai/outbound/SocketProcess.java @@ -32,9 +32,11 @@ import com.eactive.eai.control.SocketSender; import com.eactive.eai.control.Transform; import com.eactive.eai.env.ElinkConfig; import com.eactive.eai.inbound.processor.Processor; +import com.eactive.eai.message.StandardItem; import com.eactive.eai.message.StandardMessage; import com.eactive.eai.message.manager.StandardMessageManager; import com.eactive.eai.message.parser.StandardReader; +import com.eactive.eai.message.service.InterfaceMapper; import com.ext.eai.common.stdmessage.STDMessageKeys; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonNode; @@ -458,8 +460,31 @@ public class SocketProcess extends DefaultProcess { String txTmotTktm = prop.getProperty("timeout", "50"); setTimeout(this.reqEaiMsg, StringUtil.stringFormat(txTmotTktm, true, '0', 3)); + String returnType = getReturnType(this.reqEaiMsg); + + if( STDMessageKeys.SEND_RECV_CD_RECV.equals(returnType) ) { //소켓이고 비동기Outbound인데, 표준메세지 요청구분가 R은 A-S 패턴의 응답 일떄만, 아래 로직(메세지부를 제거하고 보냄.) + + StandardMessage standardMessage = this.reqEaiMsg.getStandardMessage(); + + final String MESSAGE_PART = "Message"; + final String MESSAGE_PART_HEADER_PART = "Message.Msg_Header"; + final String MESSAGE_PART_BODY_PART = "Message.Msg_Body"; + + if (!com.eactive.eai.adapter.Keys.IF_STANDARD.equals(this.adptrMsgPtrnCd)) { + + StandardItem messagePart = standardMessage.findItem(MESSAGE_PART); + messagePart.setHidden(true); + messagePart.setSize(0); + + StandardItem messageHeaderPart = standardMessage.findItem(MESSAGE_PART_HEADER_PART); + messageHeaderPart.setSize(0); + StandardItem messageBodyPart = standardMessage.findItem(MESSAGE_PART_BODY_PART); + messageBodyPart.setSize(0); + } + } this.reqObject = makeStandardMessageData(this.reqEaiMsg, this.adptrMsgType, this.reqObject, this.outboundCharset); + if(this.reqObject instanceof String) { this.reqObject = ((String) this.reqObject).getBytes(this.outboundCharset); }