org.apache.qpid.server.protocol
Class ProtocolEngine_0_10
java.lang.Object
org.apache.qpid.transport.network.InputHandler
org.apache.qpid.server.protocol.ProtocolEngine_0_10
- All Implemented Interfaces:
- org.apache.qpid.protocol.ProtocolEngine, ConfiguredObject<ConnectionConfigType,ConnectionConfig>, ConnectionConfig, org.apache.qpid.transport.Receiver<ByteBuffer>
public class ProtocolEngine_0_10
- extends org.apache.qpid.transport.network.InputHandler
- implements org.apache.qpid.protocol.ProtocolEngine, ConnectionConfig
Nested classes/interfaces inherited from class org.apache.qpid.transport.network.InputHandler |
org.apache.qpid.transport.network.InputHandler.State |
Methods inherited from class org.apache.qpid.transport.network.InputHandler |
exception, received |
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, received |
MAX_FRAME_SIZE
public static final int MAX_FRAME_SIZE
- See Also:
- Constant Field Values
ProtocolEngine_0_10
public ProtocolEngine_0_10(ServerConnection conn,
org.apache.qpid.transport.NetworkDriver networkDriver,
IApplicationRegistry appRegistry)
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
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
readerIdle
public void readerIdle()
- Specified by:
readerIdle
in interface org.apache.qpid.protocol.ProtocolEngine
getVirtualHost
public VirtualHostConfig getVirtualHost()
- Specified by:
getVirtualHost
in interface ConnectionConfig
getAddress
public String getAddress()
- Specified by:
getAddress
in interface ConnectionConfig
isIncoming
public Boolean isIncoming()
- Specified by:
isIncoming
in interface ConnectionConfig
isSystemConnection
public Boolean isSystemConnection()
- Specified by:
isSystemConnection
in interface ConnectionConfig
isFederationLink
public Boolean isFederationLink()
- Specified by:
isFederationLink
in interface ConnectionConfig
getAuthId
public String getAuthId()
- Specified by:
getAuthId
in interface ConnectionConfig
getRemoteProcessName
public String getRemoteProcessName()
- Specified by:
getRemoteProcessName
in interface ConnectionConfig
getRemotePID
public Integer getRemotePID()
- Specified by:
getRemotePID
in interface ConnectionConfig
getRemoteParentPID
public Integer getRemoteParentPID()
- Specified by:
getRemoteParentPID
in interface ConnectionConfig
getConfigStore
public ConfigStore getConfigStore()
- Specified by:
getConfigStore
in interface ConnectionConfig
getId
public UUID getId()
- Specified by:
getId
in interface ConfiguredObject<ConnectionConfigType,ConnectionConfig>
getConfigType
public ConnectionConfigType getConfigType()
- Specified by:
getConfigType
in interface ConfiguredObject<ConnectionConfigType,ConnectionConfig>
getParent
public ConfiguredObject getParent()
- Specified by:
getParent
in interface ConfiguredObject<ConnectionConfigType,ConnectionConfig>
isDurable
public boolean isDurable()
- Specified by:
isDurable
in interface ConfiguredObject<ConnectionConfigType,ConnectionConfig>
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()
- Specified by:
getCreateTime
in interface ConfiguredObject<ConnectionConfigType,ConnectionConfig>
isShadow
public Boolean isShadow()
- Specified by:
isShadow
in interface ConnectionConfig
mgmtClose
public void mgmtClose()
- Specified by:
mgmtClose
in interface ConnectionConfig
Licensed to the Apache Software Foundation