diff --git a/src/main/java/com/eactive/eai/outbound/SocketProcess.java b/src/main/java/com/eactive/eai/outbound/SocketProcess.java index d3912f7..08c8af5 100644 --- a/src/main/java/com/eactive/eai/outbound/SocketProcess.java +++ b/src/main/java/com/eactive/eai/outbound/SocketProcess.java @@ -9,7 +9,6 @@ import com.eactive.eai.adapter.AdapterVO; import com.eactive.eai.adapter.socket2.EAIConnectException; import com.eactive.eai.adapter.socket2.EAINoAvailableConnectionException; import com.eactive.eai.adapter.socket2.EAITimeoutException; -import com.eactive.eai.adapter.socket2.SocketAdapterFacade; import com.eactive.eai.common.EAIKeys; import com.eactive.eai.common.exception.ExceptionUtil; import com.eactive.eai.common.header.HeaderAction; @@ -32,6 +31,7 @@ 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; @@ -481,6 +481,30 @@ public class SocketProcess extends DefaultProcess { } } } + + @Override + protected void setRcvLogInfoExtend() throws Exception { + + super.setRcvLogInfoExtend(); + + 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)) { + + StandardMessage standardMessage = this.resEaiMsg.getStandardMessage(); + + 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); + } + } public void getTopicProperty() throws Exception { PropManager propManager = PropManager.getInstance();