org.apache.qpid.server.protocol
Class MultiVersionProtocolEngine
java.lang.Object
org.apache.qpid.server.protocol.MultiVersionProtocolEngine
- All Implemented Interfaces:
- org.apache.qpid.protocol.ProtocolEngine, org.apache.qpid.transport.Receiver<ByteBuffer>
public class MultiVersionProtocolEngine
- extends Object
- implements org.apache.qpid.protocol.ProtocolEngine
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MultiVersionProtocolEngine
public MultiVersionProtocolEngine(IApplicationRegistry appRegistry,
String fqdn,
Set<MultiVersionProtocolEngineFactory.VERSION> supported,
org.apache.qpid.transport.NetworkDriver networkDriver)
setNetworkDriver
public void setNetworkDriver(org.apache.qpid.transport.NetworkDriver driver)
- Specified by:
setNetworkDriver
in interface org.apache.qpid.protocol.ProtocolEngine
getRemoteAddress
public SocketAddress getRemoteAddress()
- Specified by:
getRemoteAddress
in interface org.apache.qpid.protocol.ProtocolEngine
getLocalAddress
public SocketAddress getLocalAddress()
- Specified by:
getLocalAddress
in interface org.apache.qpid.protocol.ProtocolEngine
getWrittenBytes
public long getWrittenBytes()
- Specified by:
getWrittenBytes
in interface org.apache.qpid.protocol.ProtocolEngine
getReadBytes
public long getReadBytes()
- Specified by:
getReadBytes
in interface org.apache.qpid.protocol.ProtocolEngine
closed
public void closed()
- Specified by:
closed
in interface org.apache.qpid.protocol.ProtocolEngine
- Specified by:
closed
in interface org.apache.qpid.transport.Receiver<ByteBuffer>
writerIdle
public void writerIdle()
- Specified by:
writerIdle
in interface org.apache.qpid.protocol.ProtocolEngine
readerIdle
public void readerIdle()
- Specified by:
readerIdle
in interface org.apache.qpid.protocol.ProtocolEngine
received
public void received(ByteBuffer msg)
- Specified by:
received
in interface org.apache.qpid.transport.Receiver<ByteBuffer>
exception
public void exception(Throwable t)
- Specified by:
exception
in interface org.apache.qpid.transport.Receiver<ByteBuffer>
Licensed to the Apache Software Foundation