public class ServerConnection extends Connection
Connection.SessionFactory, Connection.State
Modifier and Type | Field and Description |
---|---|
static long |
CLOSE_OK_TIMEOUT |
MAX_CHANNEL_MAX, MIN_USABLE_CHANNEL_NUM
Constructor and Description |
---|
ServerConnection(long connectionId,
Broker<?> broker,
AmqpPort<?> port,
Transport transport,
AMQPConnection_0_10 serverProtocolEngine) |
addConnectionListener, addFrameSizeObserver, close, close, closeCode, connect, connect, connect, createSession, createSession, createSession, createSession, createSession, createSession, createSession, createSession, createSession, dispatch, exception, flush, getChannelMax, getChannels, getConnectionSettings, getListeners, getLocalAddress, getNetworkConnection, getRemoteSocketAddress, getSaslClient, getSecurityLayer, getSender, getServerProperties, getSession, getUserID, hasSessionWithName, isClosing, isConnectionLost, isConnectionResuming, isMessageCompressionSupported, isRedirecting, isVirtualHostPropertiesSupported, notifyFailoverRequired, resume, setConnectionDelegate, setMaxFrameSize, setNetworkConnection, setRedirecting, setSender, setServerProperties, setSessionFactory, setUserID, toString
public static final long CLOSE_OK_TIMEOUT
public ServerConnection(long connectionId, Broker<?> broker, AmqpPort<?> port, Transport transport, AMQPConnection_0_10 serverProtocolEngine)
public Object getReference()
public Broker<?> getBroker()
protected void invoke(Method method)
invoke
in class Connection
protected void setState(Connection.State state)
setState
in class Connection
public ServerConnectionDelegate getConnectionDelegate()
getConnectionDelegate
in class Connection
public AMQPConnection_0_10 getAmqpConnection()
public VirtualHostImpl<?,?,?> getVirtualHost()
public void setVirtualHost(VirtualHostImpl<?,?,?> virtualHost)
public AmqpPort<?> getPort()
public Transport getTransport()
public void closeSessionAsync(ServerSession session, AMQConstant cause, String message)
public void exception(Throwable t)
exception
in interface ProtocolEventReceiver
exception
in class Connection
public void received(ProtocolEvent event)
received
in interface ProtocolEventReceiver
received
in class Connection
public String toLogString()
public void sendConnectionCloseAsync(AMQConstant cause, String message)
protected void sendConnectionClose(ConnectionCloseCode replyCode, String replyText, Option... _options)
sendConnectionClose
in class Connection
protected void performDeleteTasks()
public void block()
public void unblock()
public void registerSession(Session ssn)
registerSession
in class Connection
public void removeSession(Session ssn)
removeSession
in class Connection
public List<ServerSession> getSessionModels()
public Subject getAuthorizedSubject()
public void setAuthorizedSubject(Subject authorizedSubject)
authorizedSubject
- public Principal getAuthorizedPrincipal()
public long getConnectionId()
public String getRemoteAddressString()
public void closed()
closed
in interface ProtocolEventReceiver
closed
in class Connection
public void receivedComplete()
public void send(ProtocolEvent event)
send
in interface ProtocolEventSender
send
in class Connection
public String getClientId()
public String getRemoteContainerName()
public String getClientVersion()
public String getClientProduct()
public long getSessionCountLimit()
public Principal getPeerPrincipal()
public void setRemoteAddress(SocketAddress remoteAddress)
setRemoteAddress
in class Connection
public void setLocalAddress(SocketAddress localAddress)
setLocalAddress
in class Connection
public void doHeartBeat()
doHeartBeat
in class Connection
public int getMessageCompressionThreshold()
public int getMaxMessageSize()
public void transportStateChanged()
public void notifyWork()
public void closeAndIgnoreFutureInput()
public boolean isIgnoreFutureInput()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.