org.apache.qpid.server.protocol
Class ProtocolEngine_0_10

java.lang.Object
  extended by org.apache.qpid.transport.network.InputHandler
      extended by 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 Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.transport.network.InputHandler
org.apache.qpid.transport.network.InputHandler.State
 
Field Summary
static int MAX_FRAME_SIZE
           
 
Constructor Summary
ProtocolEngine_0_10(ServerConnection conn, org.apache.qpid.transport.NetworkDriver networkDriver, IApplicationRegistry appRegistry)
           
 
Method Summary
 void closed()
           
 String getAddress()
           
 String getAuthId()
           
 ConfigStore getConfigStore()
           
 ConnectionConfigType getConfigType()
           
 long getCreateTime()
           
 UUID getId()
           
 SocketAddress getLocalAddress()
           
 ConfiguredObject getParent()
           
 long getReadBytes()
           
 SocketAddress getRemoteAddress()
           
 Integer getRemoteParentPID()
           
 Integer getRemotePID()
           
 String getRemoteProcessName()
           
 VirtualHostConfig getVirtualHost()
           
 long getWrittenBytes()
           
 boolean isDurable()
           
 Boolean isFederationLink()
           
 Boolean isIncoming()
           
 Boolean isShadow()
           
 Boolean isSystemConnection()
           
 void mgmtClose()
           
 void readerIdle()
           
 void setNetworkDriver(org.apache.qpid.transport.NetworkDriver driver)
           
 void writerIdle()
           
 
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
 

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.NetworkDriver networkDriver,
                           IApplicationRegistry appRegistry)
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

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