From 44613adf755058e4a838c80f9b9e5ce8a26adf4f Mon Sep 17 00:00:00 2001 From: James Strachan Date: Thu, 23 Feb 2006 18:11:49 +0000 Subject: [PATCH] minor refactor for easier debugging git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@380179 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/activemq/transport/tcp/TcpTransportServer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java index 0e3fcfc72b..f7ded68f0f 100755 --- a/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/tcp/TcpTransportServer.java @@ -20,6 +20,7 @@ import org.activeio.command.WireFormat; import org.activeio.command.WireFormatFactory; import org.apache.activemq.command.BrokerInfo; import org.apache.activemq.openwire.OpenWireFormatFactory; +import org.apache.activemq.transport.Transport; import org.apache.activemq.transport.TransportServerThreadSupport; import org.apache.activemq.util.ServiceStopper; import org.apache.commons.logging.Log; @@ -102,7 +103,8 @@ public class TcpTransportServer extends TransportServerThreadSupport { HashMap options = new HashMap(); WireFormat format = wireFormatFactory.createWireFormat(); TcpTransport transport = new TcpTransport(format, socket); - getAcceptListener().onAccept(transportFactory.configure(transport, format, options)); + Transport configuredTransport = transportFactory.configure(transport, format, options); + getAcceptListener().onAccept(configuredTransport); } } }