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:

LogSubject, AMQConnectionModel<ServerConnection,ServerSession>, AuthorizationHolder, StatisticsGatherer, Deletable<ServerConnection>, 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<ServerConnection,ServerSession>, LogSubject, AuthorizationHolder

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, MAX_CHANNEL_MAX, MIN_USABLE_CHANNEL_NUM

Constructor Summary

Constructors

Constructor and Description
ServerConnection(long connectionId, Broker broker)

Method Summary

Methods

Modifier and Type	Method and Description
void	addDeleteTask(Action<? super ServerConnection> task)
void	addSessionListener(SessionModelListener listener)
void	block()
void	close(org.apache.qpid.protocol.AMQConstant cause, String message)
void	closed()
void	closeSession(ServerSession session, org.apache.qpid.protocol.AMQConstant cause, String message)
void	doHeartBeat()
void	exception(Throwable t)
Principal	getAuthorizedPrincipal()
Subject	getAuthorizedSubject()
String	getClientId()
String	getClientProduct()
String	getClientVersion()
ServerConnectionDelegate	getConnectionDelegate()
long	getConnectionId()
StatisticsCounter	getDataDeliveryStatistics()
StatisticsCounter	getDataReceiptStatistics()
long	getLastIoTime()
LogSubject	getLogSubject()
int	getMessageCompressionThreshold()
StatisticsCounter	getMessageDeliveryStatistics()
StatisticsCounter	getMessageReceiptStatistics()
Principal	getPeerPrincipal()
Port<?>	getPort()
Object	getReference()
String	getRemoteAddressString()
String	getRemoteContainerName()
String	getRemoteProcessPid()
long	getSessionCountLimit()
List<ServerSession>	getSessionModels()
Transport	getTransport()
VirtualHostImpl<?,?,?>	getVirtualHost()
String	getVirtualHostName()
protected void	invoke(org.apache.qpid.transport.Method method)
boolean	isSessionNameUnique(byte[] name)
boolean	isStopped()
protected void	logClosed()
void	onOpen(Runnable task)
protected void	performDeleteTasks()
void	received(org.apache.qpid.transport.ProtocolEvent event)
void	receivedComplete()
void	registerMessageDelivered(long messageSize)
void	registerMessageReceived(long messageSize, long timestamp)
void	registerSession(org.apache.qpid.transport.Session ssn)
void	removeDeleteTask(Action<? super ServerConnection> task)
void	removeSession(org.apache.qpid.transport.Session ssn)
void	removeSessionListener(SessionModelListener listener)
void	resetStatistics()
void	send(org.apache.qpid.transport.ProtocolEvent event)
void	setAuthorizedSubject(Subject authorizedSubject) Sets the authorized subject.
void	setConnectionDelegate(ServerConnectionDelegate delegate)
void	setLocalAddress(SocketAddress localAddress)
void	setPort(Port<?> port)
void	setRemoteAddress(SocketAddress remoteAddress)
protected void	setState(org.apache.qpid.transport.Connection.State state)
void	setTransport(Transport transport)
void	setVirtualHost(VirtualHostImpl<?,?,?> virtualHost)
void	stop()
String	toLogString()
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, getIdleTimeout, getLocalAddress, getNetworkConnection, getRemoteAddress, getSaslClient, getSecurityLayer, getSender, getServerProperties, getSession, getUserID, hasSessionWithName, isConnectionResuming, isMessageCompressionSupported, mgmtClose, notifyFailoverRequired, resume, setConnectionDelegate, setIdleTimeout, setMaxFrameSize, setNetworkConnection, 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

getRemoteAddress

Constructor Detail

ServerConnection

public ServerConnection(long connectionId,
                Broker broker)

Method Detail

getReference

public Object getReference()

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

logClosed

protected void logClosed()

getConnectionDelegate

public ServerConnectionDelegate getConnectionDelegate()

Overrides:

getConnectionDelegate in class org.apache.qpid.transport.Connection

setConnectionDelegate

public void setConnectionDelegate(ServerConnectionDelegate delegate)

getVirtualHost

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

Specified by:

getVirtualHost in interface AMQConnectionModel<ServerConnection,ServerSession>

setVirtualHost

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

getVirtualHostName

public String getVirtualHostName()

Specified by:

getVirtualHostName in interface AMQConnectionModel<ServerConnection,ServerSession>

getPort

public Port<?> getPort()

Specified by:

getPort in interface AMQConnectionModel<ServerConnection,ServerSession>

setPort

public void setPort(Port<?> port)

getTransport

public Transport getTransport()

Specified by:

getTransport in interface AMQConnectionModel<ServerConnection,ServerSession>

stop

public void stop()

Specified by:

stop in interface AMQConnectionModel<ServerConnection,ServerSession>

isStopped

public boolean isStopped()

Specified by:

isStopped in interface AMQConnectionModel<ServerConnection,ServerSession>

setTransport

public void setTransport(Transport transport)

onOpen

public void onOpen(Runnable task)

closeSession

public void closeSession(ServerSession session,
                org.apache.qpid.protocol.AMQConstant cause,
                String message)

Specified by:

closeSession in interface AMQConnectionModel<ServerConnection,ServerSession>

getLogSubject

public LogSubject getLogSubject()

Specified by:

getLogSubject in interface AMQConnectionModel<ServerConnection,ServerSession>

exception

public void exception(Throwable t)

Specified by:

exception in interface org.apache.qpid.transport.Receiver<org.apache.qpid.transport.ProtocolEvent>

Overrides:

exception in class org.apache.qpid.transport.Connection

received

public void received(org.apache.qpid.transport.ProtocolEvent event)

Specified by:

received in interface org.apache.qpid.transport.Receiver<org.apache.qpid.transport.ProtocolEvent>

Overrides:

received in class org.apache.qpid.transport.Connection

toLogString

public String toLogString()

Specified by:

toLogString in interface LogSubject

close

public void close(org.apache.qpid.protocol.AMQConstant cause,
         String message)

Specified by:

close in interface AMQConnectionModel<ServerConnection,ServerSession>

performDeleteTasks

protected void performDeleteTasks()

block

public void block()

Specified by:

block in interface AMQConnectionModel<ServerConnection,ServerSession>

unblock

public void unblock()

Specified by:

unblock in interface AMQConnectionModel<ServerConnection,ServerSession>

registerSession

public void registerSession(org.apache.qpid.transport.Session ssn)

Overrides:

registerSession in class org.apache.qpid.transport.Connection

removeSession

public void removeSession(org.apache.qpid.transport.Session ssn)

Overrides:

removeSession in class org.apache.qpid.transport.Connection

getSessionModels

public List<ServerSession> getSessionModels()

Specified by:

getSessionModels in interface AMQConnectionModel<ServerConnection,ServerSession>

registerMessageDelivered

public void registerMessageDelivered(long messageSize)

Specified by:

registerMessageDelivered in interface StatisticsGatherer

registerMessageReceived

public void registerMessageReceived(long messageSize,
                           long timestamp)

Specified by:

registerMessageReceived in interface StatisticsGatherer

getMessageReceiptStatistics

public StatisticsCounter getMessageReceiptStatistics()

Specified by:

getMessageReceiptStatistics in interface StatisticsGatherer

getDataReceiptStatistics

public StatisticsCounter getDataReceiptStatistics()

Specified by:

getDataReceiptStatistics in interface StatisticsGatherer

getMessageDeliveryStatistics

public StatisticsCounter getMessageDeliveryStatistics()

Specified by:

getMessageDeliveryStatistics in interface StatisticsGatherer

getDataDeliveryStatistics

public StatisticsCounter getDataDeliveryStatistics()

Specified by:

getDataDeliveryStatistics in interface StatisticsGatherer

resetStatistics

public void resetStatistics()

Specified by:

resetStatistics in interface StatisticsGatherer

getAuthorizedSubject

public Subject getAuthorizedSubject()

Specified by:

getAuthorizedSubject in interface AuthorizationHolder

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()

Specified by:

getAuthorizedPrincipal in interface AMQConnectionModel<ServerConnection,ServerSession>

Specified by:

getAuthorizedPrincipal in interface AuthorizationHolder

getConnectionId

public long getConnectionId()

Specified by:

getConnectionId in interface AMQConnectionModel<ServerConnection,ServerSession>

isSessionNameUnique

public boolean isSessionNameUnique(byte[] name)

Specified by:

isSessionNameUnique in interface AMQConnectionModel<ServerConnection,ServerSession>

getRemoteAddressString

public String getRemoteAddressString()

Specified by:

getRemoteAddressString in interface AMQConnectionModel<ServerConnection,ServerSession>

getRemoteProcessPid

public String getRemoteProcessPid()

Specified by:

getRemoteProcessPid in interface AMQConnectionModel<ServerConnection,ServerSession>

closed

public void closed()

Specified by:

closed in interface org.apache.qpid.transport.Receiver<org.apache.qpid.transport.ProtocolEvent>

Overrides:

closed in class org.apache.qpid.transport.Connection

receivedComplete

public void receivedComplete()

send

public void send(org.apache.qpid.transport.ProtocolEvent event)

Specified by:

send in interface org.apache.qpid.transport.Sender<org.apache.qpid.transport.ProtocolEvent>

Overrides:

send in class org.apache.qpid.transport.Connection

getLastIoTime

public long getLastIoTime()

Specified by:

getLastIoTime in interface AMQConnectionModel<ServerConnection,ServerSession>

getClientId

public String getClientId()

Specified by:

getClientId in interface AMQConnectionModel<ServerConnection,ServerSession>

getRemoteContainerName

public String getRemoteContainerName()

Specified by:

getRemoteContainerName in interface AMQConnectionModel<ServerConnection,ServerSession>

addSessionListener

public void addSessionListener(SessionModelListener listener)

Specified by:

addSessionListener in interface AMQConnectionModel<ServerConnection,ServerSession>

removeSessionListener

public void removeSessionListener(SessionModelListener listener)

Specified by:

removeSessionListener in interface AMQConnectionModel<ServerConnection,ServerSession>

getClientVersion

public String getClientVersion()

Specified by:

getClientVersion in interface AMQConnectionModel<ServerConnection,ServerSession>

getClientProduct

public String getClientProduct()

Specified by:

getClientProduct in interface AMQConnectionModel<ServerConnection,ServerSession>

getSessionCountLimit

public long getSessionCountLimit()

Specified by:

getSessionCountLimit in interface AMQConnectionModel<ServerConnection,ServerSession>

getPeerPrincipal

public Principal getPeerPrincipal()

setRemoteAddress

public void setRemoteAddress(SocketAddress remoteAddress)

Overrides:

setRemoteAddress in class org.apache.qpid.transport.Connection

setLocalAddress

public void setLocalAddress(SocketAddress localAddress)

Overrides:

setLocalAddress in class org.apache.qpid.transport.Connection

doHeartBeat

public void doHeartBeat()

Overrides:

doHeartBeat in class org.apache.qpid.transport.Connection

addDeleteTask

public void addDeleteTask(Action<? super ServerConnection> task)

Specified by:

addDeleteTask in interface Deletable<ServerConnection>

removeDeleteTask

public void removeDeleteTask(Action<? super ServerConnection> task)

Specified by:

removeDeleteTask in interface Deletable<ServerConnection>

getMessageCompressionThreshold

public int getMessageCompressionThreshold()