diff --git a/src/main/java/com/eactive/eai/outbound/SocketProcess.java b/src/main/java/com/eactive/eai/outbound/SocketProcess.java index 08c8af5..d3912f7 100644 --- a/src/main/java/com/eactive/eai/outbound/SocketProcess.java +++ b/src/main/java/com/eactive/eai/outbound/SocketProcess.java @@ -9,6 +9,7 @@ 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; @@ -31,7 +32,6 @@ 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,30 +481,6 @@ 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();