org.apache.qpid.server.protocol
Class MultiVersionProtocolEngine

java.lang.Object
  extended by 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


Constructor Summary
MultiVersionProtocolEngine(IApplicationRegistry appRegistry, String fqdn, Set<MultiVersionProtocolEngineFactory.VERSION> supported, org.apache.qpid.transport.NetworkDriver networkDriver)
           
 
Method Summary
 void closed()
           
 void exception(Throwable t)
           
 SocketAddress getLocalAddress()
           
 long getReadBytes()
           
 SocketAddress getRemoteAddress()
           
 long getWrittenBytes()
           
 void readerIdle()
           
 void received(ByteBuffer msg)
           
 void setNetworkDriver(org.apache.qpid.transport.NetworkDriver driver)
           
 void writerIdle()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MultiVersionProtocolEngine

public MultiVersionProtocolEngine(IApplicationRegistry appRegistry,
                                  String fqdn,
                                  Set<MultiVersionProtocolEngineFactory.VERSION> supported,
                                  org.apache.qpid.transport.NetworkDriver networkDriver)
Method Detail

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