diff --git a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java index a102d144e1..8f12a2728f 100755 --- a/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java +++ b/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java @@ -155,16 +155,6 @@ public class UdpTransportFactory extends TransportFactory { protected Transport configureClientSideNegotiator(Transport transport, WireFormat format, final UdpTransport udpTransport) { return new ResponseRedirectInterceptor(transport, udpTransport); - /* - * transport = new WireFormatNegotiator(transport, - * asOpenWireFormat(format), udpTransport.getMinmumWireFormatVersion()) { - * protected void onWireFormatNegotiated(WireFormatInfo info) { // lets - * switch to the target endpoint // based on the last packet that was - * received // so that all future requests go to the newly created UDP - * channel Endpoint from = info.getFrom(); - * System.out.println("####Ęsetting the client side target to: " + - * from); udpTransport.setTargetEndpoint(from); } }; return transport; - */ } protected OpenWireFormat asOpenWireFormat(WireFormat wf) {