diff options
Diffstat (limited to 'qpid/java/common/src/test')
| -rw-r--r-- | qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java b/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java index e9005ab2e4..f74051aa32 100644 --- a/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java +++ b/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java @@ -19,13 +19,13 @@ package org.apache.qpid.transport.network.io; +import java.net.Socket; +import java.nio.ByteBuffer; + import org.apache.qpid.transport.Binding; import org.apache.qpid.transport.Sender; import org.apache.qpid.transport.util.Logger; -import java.net.Socket; -import java.nio.ByteBuffer; - /** * This class provides a socket based transport using the java.io * classes. @@ -70,7 +70,7 @@ public final class IoTransport<E> 2*readBufferSize, timeout); this.receiver.initiate(); - ios.registerCloseListener(this.receiver); + ios.setReceiver(this.receiver); } public Sender<ByteBuffer> getSender() |