diff options
Diffstat (limited to 'java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngine.java')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngine.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngine.java b/java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngine.java index fd651a2b66..31953ea6ab 100644 --- a/java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngine.java +++ b/java/common/src/main/java/org/apache/qpid/protocol/ProtocolEngine.java @@ -21,11 +21,10 @@ package org.apache.qpid.protocol; import java.net.SocketAddress; -import java.nio.ByteBuffer; +import org.apache.qpid.framing.AMQDataBlock; +import org.apache.qpid.transport.NetworkDriver; import org.apache.qpid.transport.Receiver; -import org.apache.qpid.transport.Sender; -import org.apache.qpid.transport.network.NetworkConnection; /** * A ProtocolEngine is a Receiver for java.nio.ByteBuffers. It takes the data passed to it in the received @@ -33,6 +32,9 @@ import org.apache.qpid.transport.network.NetworkConnection; */ public interface ProtocolEngine extends Receiver<java.nio.ByteBuffer> { + // Sets the network driver providing data for this ProtocolEngine + void setNetworkDriver (NetworkDriver driver); + // Returns the remote address of the NetworkDriver SocketAddress getRemoteAddress(); @@ -56,6 +58,4 @@ public interface ProtocolEngine extends Receiver<java.nio.ByteBuffer> void readerIdle(); - public void setNetworkConnection(NetworkConnection network, Sender<ByteBuffer> sender); - }
\ No newline at end of file |