mirror of https://github.com/apache/activemq.git
removed unused code for AMQ-822
git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@429776 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
08e4b7ba19
commit
c96f327bfa
|
@ -155,16 +155,6 @@ public class UdpTransportFactory extends TransportFactory {
|
||||||
|
|
||||||
protected Transport configureClientSideNegotiator(Transport transport, WireFormat format, final UdpTransport udpTransport) {
|
protected Transport configureClientSideNegotiator(Transport transport, WireFormat format, final UdpTransport udpTransport) {
|
||||||
return new ResponseRedirectInterceptor(transport, 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) {
|
protected OpenWireFormat asOpenWireFormat(WireFormat wf) {
|
||||||
|
|
Loading…
Reference in New Issue