org.apache.qpid.server.protocol.v0_10

Class ProtocolEngine_0_10

java.lang.Object

org.apache.qpid.transport.network.InputHandler

org.apache.qpid.server.protocol.v0_10.ProtocolEngine_0_10

All Implemented Interfaces:

org.apache.qpid.protocol.ProtocolEngine, org.apache.qpid.protocol.ServerProtocolEngine, org.apache.qpid.transport.FrameSizeObserver, org.apache.qpid.transport.network.TransportActivity, org.apache.qpid.transport.Receiver<ByteBuffer>

public class ProtocolEngine_0_10
extends org.apache.qpid.transport.network.InputHandler
implements org.apache.qpid.protocol.ServerProtocolEngine

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.transport.network.InputHandler

org.apache.qpid.transport.network.InputHandler.State

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_FRAME_SIZE

Constructor Summary

Constructors

Constructor and Description
ProtocolEngine_0_10(ServerConnection conn, org.apache.qpid.transport.network.NetworkConnection network, Port port, Transport transport)

Method Summary

Methods

Modifier and Type	Method and Description
void	closed()
String	getAddress()
String	getAuthId()
long	getConnectionId()
long	getCreateTime()
long	getLastReadTime()
long	getLastWriteTime()
SocketAddress	getLocalAddress()
long	getReadBytes()
SocketAddress	getRemoteAddress()
Subject	getSubject()
long	getWrittenBytes()
boolean	isDurable()
void	readerIdle()
void	received(ByteBuffer buf)
void	setNetworkConnection(org.apache.qpid.transport.network.NetworkConnection network, org.apache.qpid.transport.Sender<ByteBuffer> sender)
void	writerIdle()

Methods inherited from class org.apache.qpid.transport.network.InputHandler

exception, setMaxFrameSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.qpid.transport.Receiver

exception

Field Detail

MAX_FRAME_SIZE

public static final int MAX_FRAME_SIZE

See Also:

Constant Field Values

Constructor Detail

ProtocolEngine_0_10

public ProtocolEngine_0_10(ServerConnection conn,
                   org.apache.qpid.transport.network.NetworkConnection network,
                   Port port,
                   Transport transport)

Method Detail

setNetworkConnection

public void setNetworkConnection(org.apache.qpid.transport.network.NetworkConnection network,
                        org.apache.qpid.transport.Sender<ByteBuffer> sender)

Specified by:

setNetworkConnection in interface org.apache.qpid.protocol.ProtocolEngine

getLastReadTime

public long getLastReadTime()

Specified by:

getLastReadTime in interface org.apache.qpid.transport.network.TransportActivity

getLastWriteTime

public long getLastWriteTime()

Specified by:

getLastWriteTime in interface org.apache.qpid.transport.network.TransportActivity

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

received

public void received(ByteBuffer buf)

Specified by:

received in interface org.apache.qpid.transport.Receiver<ByteBuffer>

Overrides:

received in class org.apache.qpid.transport.network.InputHandler

getReadBytes

public long getReadBytes()

Specified by:

getReadBytes in interface org.apache.qpid.protocol.ProtocolEngine

getWrittenBytes

public long getWrittenBytes()

Specified by:

getWrittenBytes in interface org.apache.qpid.protocol.ProtocolEngine

writerIdle

public void writerIdle()

Specified by:

writerIdle in interface org.apache.qpid.protocol.ProtocolEngine

Specified by:

writerIdle in interface org.apache.qpid.transport.network.TransportActivity

readerIdle

public void readerIdle()

Specified by:

readerIdle in interface org.apache.qpid.protocol.ProtocolEngine

Specified by:

readerIdle in interface org.apache.qpid.transport.network.TransportActivity

getAddress

public String getAddress()

getAuthId

public String getAuthId()

isDurable

public boolean isDurable()

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>

Overrides:

closed in class org.apache.qpid.transport.network.InputHandler

getCreateTime

public long getCreateTime()

getConnectionId

public long getConnectionId()

Specified by:

getConnectionId in interface org.apache.qpid.protocol.ServerProtocolEngine

getSubject

public Subject getSubject()

Specified by:

getSubject in interface org.apache.qpid.protocol.ServerProtocolEngine