org.apache.qpid.server.protocol.v0_10

Class ServerConnection

java.lang.Object

org.apache.qpid.transport.ConnectionInvoker

org.apache.qpid.transport.Connection

org.apache.qpid.server.protocol.v0_10.ServerConnection

All Implemented Interfaces:

ProtocolEventReceiver, ProtocolEventSender

public class ServerConnection
extends Connection

Nested Class Summary

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

Connection.SessionFactory, Connection.State

Field Summary

Fields

Modifier and Type	Field and Description
static long	CLOSE_OK_TIMEOUT

Fields inherited from class org.apache.qpid.transport.Connection

MAX_CHANNEL_MAX, MIN_USABLE_CHANNEL_NUM

Constructor Summary

Constructors

Constructor and Description
ServerConnection(long connectionId, Broker<?> broker, AmqpPort<?> port, Transport transport, AMQPConnection_0_10 serverProtocolEngine)

Method Summary

Modifier and Type	Method and Description
void	block()
void	closeAndIgnoreFutureInput()
void	closed()
void	closeSessionAsync(ServerSession session, AMQConstant cause, String message)
void	doHeartBeat()
void	exception(Throwable t)
AMQPConnection_0_10	getAmqpConnection()
Principal	getAuthorizedPrincipal()
Subject	getAuthorizedSubject()
Broker<?>	getBroker()
String	getClientId()
String	getClientProduct()
String	getClientVersion()
ServerConnectionDelegate	getConnectionDelegate()
long	getConnectionId()
int	getMaxMessageSize()
int	getMessageCompressionThreshold()
Principal	getPeerPrincipal()
AmqpPort<?>	getPort()
Object	getReference()
String	getRemoteAddressString()
String	getRemoteContainerName()
long	getSessionCountLimit()
List<ServerSession>	getSessionModels()
Transport	getTransport()
VirtualHostImpl<?,?,?>	getVirtualHost()
protected void	invoke(Method method)
boolean	isIgnoreFutureInput()
void	notifyWork()
protected void	performDeleteTasks()
Iterator<Runnable>	processPendingIterator()
void	received(ProtocolEvent event)
void	receivedComplete()
void	registerSession(Session ssn)
void	removeSession(Session ssn)
void	send(ProtocolEvent event)
protected void	sendConnectionClose(ConnectionCloseCode replyCode, String replyText, Option... _options)
void	sendConnectionCloseAsync(AMQConstant cause, String message)
void	setAuthorizedSubject(Subject authorizedSubject) Sets the authorized subject.
void	setLocalAddress(SocketAddress localAddress)
void	setRemoteAddress(SocketAddress remoteAddress)
protected void	setState(Connection.State state)
void	setVirtualHost(VirtualHostImpl<?,?,?> virtualHost)
String	toLogString()
void	transportStateChanged()
void	unblock()

Methods inherited from class org.apache.qpid.transport.Connection

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

Methods inherited from class java.lang.Object

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

Field Detail

CLOSE_OK_TIMEOUT

public static final long CLOSE_OK_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

ServerConnection

public ServerConnection(long connectionId,
                        Broker<?> broker,
                        AmqpPort<?> port,
                        Transport transport,
                        AMQPConnection_0_10 serverProtocolEngine)

Method Detail

getReference

public Object getReference()

getBroker

public Broker<?> getBroker()

invoke

protected void invoke(Method method)

Overrides:

invoke in class Connection

setState

protected void setState(Connection.State state)

Overrides:

setState in class Connection

getConnectionDelegate

public ServerConnectionDelegate getConnectionDelegate()

Overrides:

getConnectionDelegate in class Connection

getAmqpConnection

public AMQPConnection_0_10 getAmqpConnection()

getVirtualHost

public VirtualHostImpl<?,?,?> getVirtualHost()

setVirtualHost

public void setVirtualHost(VirtualHostImpl<?,?,?> virtualHost)

getPort

public AmqpPort<?> getPort()

getTransport

public Transport getTransport()

closeSessionAsync

public void closeSessionAsync(ServerSession session,
                              AMQConstant cause,
                              String message)

exception

public void exception(Throwable t)

Specified by:

exception in interface ProtocolEventReceiver

Overrides:

exception in class Connection

received

public void received(ProtocolEvent event)

Specified by:

received in interface ProtocolEventReceiver

Overrides:

received in class Connection

toLogString

public String toLogString()

sendConnectionCloseAsync

public void sendConnectionCloseAsync(AMQConstant cause,
                                     String message)

sendConnectionClose

protected void sendConnectionClose(ConnectionCloseCode replyCode,
                                   String replyText,
                                   Option... _options)

Overrides:

sendConnectionClose in class Connection

performDeleteTasks

protected void performDeleteTasks()

block

public void block()

unblock

public void unblock()

registerSession

public void registerSession(Session ssn)

Overrides:

registerSession in class Connection

removeSession

public void removeSession(Session ssn)

Overrides:

removeSession in class Connection

getSessionModels

public List<ServerSession> getSessionModels()

getAuthorizedSubject

public Subject getAuthorizedSubject()

Returns:

authorizedSubject

setAuthorizedSubject

public void setAuthorizedSubject(Subject authorizedSubject)

Sets the authorized subject. It also extracts the UsernamePrincipal from the subject and caches it for optimisation purposes.

Parameters:

authorizedSubject -

getAuthorizedPrincipal

public Principal getAuthorizedPrincipal()

getConnectionId

public long getConnectionId()

getRemoteAddressString

public String getRemoteAddressString()

closed

public void closed()

Specified by:

closed in interface ProtocolEventReceiver

Overrides:

closed in class Connection

receivedComplete

public void receivedComplete()

send

public void send(ProtocolEvent event)

Specified by:

send in interface ProtocolEventSender

Overrides:

send in class Connection

getClientId

public String getClientId()

getRemoteContainerName

public String getRemoteContainerName()

getClientVersion

public String getClientVersion()

getClientProduct

public String getClientProduct()

getSessionCountLimit

public long getSessionCountLimit()

getPeerPrincipal

public Principal getPeerPrincipal()

setRemoteAddress

public void setRemoteAddress(SocketAddress remoteAddress)

Overrides:

setRemoteAddress in class Connection

setLocalAddress

public void setLocalAddress(SocketAddress localAddress)

Overrides:

setLocalAddress in class Connection

doHeartBeat

public void doHeartBeat()

Overrides:

doHeartBeat in class Connection

getMessageCompressionThreshold

public int getMessageCompressionThreshold()

getMaxMessageSize

public int getMaxMessageSize()

transportStateChanged

public void transportStateChanged()

notifyWork

public void notifyWork()

processPendingIterator

public Iterator<Runnable> processPendingIterator()

closeAndIgnoreFutureInput

public void closeAndIgnoreFutureInput()

isIgnoreFutureInput

public boolean isIgnoreFutureInput()