org.apache.qpid.server.transport
Class ServerConnection

java.lang.Object
  extended by org.apache.qpid.transport.ConnectionInvoker
      extended by org.apache.qpid.transport.Connection
          extended by org.apache.qpid.server.transport.ServerConnection
All Implemented Interfaces:
LogSubject, AMQConnectionModel, org.apache.qpid.transport.Receiver<org.apache.qpid.transport.ProtocolEvent>, org.apache.qpid.transport.Sender<org.apache.qpid.transport.ProtocolEvent>

public class ServerConnection
extends org.apache.qpid.transport.Connection
implements AMQConnectionModel, LogSubject


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.transport.Connection
org.apache.qpid.transport.Connection.SessionFactory, org.apache.qpid.transport.Connection.State
 
Field Summary
 
Fields inherited from class org.apache.qpid.transport.Connection
log
 
Constructor Summary
ServerConnection()
           
 
Method Summary
 void closeSession(AMQSessionModel session, org.apache.qpid.protocol.AMQConstant cause, String message)
          Close the given requested Session
 ConnectionConfig getConfig()
           
 ServerConnectionDelegate getConnectionDelegate()
           
 VirtualHost getVirtualHost()
           
protected  void invoke(org.apache.qpid.transport.Method method)
           
 void onOpen(Runnable task)
           
 void setConnectionConfig(ConnectionConfig config)
           
 void setConnectionDelegate(ServerConnectionDelegate delegate)
           
protected  void setState(org.apache.qpid.transport.Connection.State state)
           
 void setVirtualHost(VirtualHost virtualHost)
           
 String toLogString()
          Provides the log message as as String.
 
Methods inherited from class org.apache.qpid.transport.Connection
addConnectionListener, close, close, closed, connect, connect, connect, connect, connect, createSession, createSession, createSession, createSession, createSession, createSession, dispatch, exception, exception, flush, getAuthorizationID, getChannelMax, getClientId, getConnectionId, getConnectionSettings, getIdleTimeout, getSaslClient, getSecurityLayer, getSender, getServerProperties, getUserID, mgmtClose, received, resume, send, setAuthorizationID, setClientId, setConnectionDelegate, setIdleTimeout, setSender, setServerProperties, setSessionFactory, setUserID, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.qpid.server.protocol.AMQConnectionModel
getConnectionId
 

Constructor Detail

ServerConnection

public ServerConnection()
Method Detail

invoke

protected void invoke(org.apache.qpid.transport.Method method)
Overrides:
invoke in class org.apache.qpid.transport.Connection

setState

protected void setState(org.apache.qpid.transport.Connection.State state)
Overrides:
setState in class org.apache.qpid.transport.Connection

getConnectionDelegate

public ServerConnectionDelegate getConnectionDelegate()
Overrides:
getConnectionDelegate in class org.apache.qpid.transport.Connection

setConnectionDelegate

public void setConnectionDelegate(ServerConnectionDelegate delegate)

getVirtualHost

public VirtualHost getVirtualHost()

setVirtualHost

public void setVirtualHost(VirtualHost virtualHost)

setConnectionConfig

public void setConnectionConfig(ConnectionConfig config)

getConfig

public ConnectionConfig getConfig()

onOpen

public void onOpen(Runnable task)

closeSession

public void closeSession(AMQSessionModel session,
                         org.apache.qpid.protocol.AMQConstant cause,
                         String message)
                  throws org.apache.qpid.AMQException
Description copied from interface: AMQConnectionModel
Close the given requested Session

Specified by:
closeSession in interface AMQConnectionModel
Throws:
org.apache.qpid.AMQException

toLogString

public String toLogString()
Description copied from interface: LogSubject
Provides the log message as as String.

Specified by:
toLogString in interface LogSubject


Licensed to the Apache Software Foundation