org.apache.qpid.server.transport

Interface AMQPConnection<C extends AMQPConnection<C>>

All Superinterfaces:

ConfiguredObject<C>, Connection<C>, Deletable<C>

All Known Implementing Classes:

AbstractAMQPConnection, AMQPConnection_0_10, AMQPConnection_0_8, AMQPConnection_1_0

public interface AMQPConnection<C extends AMQPConnection<C>>
extends Connection<C>, Deletable<C>

Field Summary

Fields inherited from interface org.apache.qpid.server.model.Connection

CLIENT_ID, CLIENT_VERSION, DEFAULT_MAX_UNCOMMITTED_IN_MEMORY_SIZE, INCOMING, LOCAL_ADDRESS, MAX_UNCOMMITTED_IN_MEMORY_SIZE, PORT, PRINCIPAL, PROPERTIES, REMOTE_ADDRESS, REMOTE_PROCESS_NAME, REMOTE_PROCESS_PID, SESSION_COUNT_LIMIT, STATE, TRANSPORT

Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject

CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, TYPE

Method Summary

Modifier and Type	Method and Description
void	alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread(boolean override)
void	block()
void	closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)
Principal	getAuthorizedPrincipal()
long	getConnectionId()
String	getRemoteAddressString()
String	getRemoteContainerName()
SocketAddress	getRemoteSocketAddress()
List<? extends AMQSessionModel<?>>	getSessionModels()
String	getVirtualHostName()
boolean	hasSessionWithName(byte[] name)
boolean	isConnectionStopped()
boolean	isIOThread()
boolean	isMessageAssignmentSuspended()
void	notifyWork()
NetworkConnectionScheduler	popScheduler()
void	pushScheduler(NetworkConnectionScheduler networkConnectionScheduler)
void	registerMessageDelivered(long size)
void	registerMessageReceived(long size, long arrivalTime)
void	reserveOutboundMessageSpace(long size)
void	resetStatistics()
void	sendConnectionCloseAsync(AMQConstant connectionForced, String reason)
void	stopConnection()
void	unblock()

Methods inherited from interface org.apache.qpid.server.model.Connection

getBytesIn, getBytesOut, getClientId, getClientVersion, getLastIoTime, getLocalAddress, getMessagesIn, getMessagesOut, getPort, getPrincipal, getProtocol, getRemoteAddress, getRemoteProcessName, getRemoteProcessPid, getSessionCount, getSessionCountLimit, getSessions, getTransport, getTransportInfo, getUnderlyingConnection, getVirtualHost, isIncoming

Methods inherited from interface org.apache.qpid.server.model.ConfiguredObject

addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getType, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync

Methods inherited from interface org.apache.qpid.server.util.Deletable

addDeleteTask, removeDeleteTask

Method Detail

isMessageAssignmentSuspended

boolean isMessageAssignmentSuspended()

alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread

void alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread(boolean override)

getConnectionId

long getConnectionId()

getAuthorizedPrincipal

Principal getAuthorizedPrincipal()

getRemoteAddressString

String getRemoteAddressString()

getVirtualHostName

String getVirtualHostName()

notifyWork

void notifyWork()

getRemoteContainerName

String getRemoteContainerName()

isConnectionStopped

boolean isConnectionStopped()

registerMessageReceived

void registerMessageReceived(long size,
                             long arrivalTime)

registerMessageDelivered

void registerMessageDelivered(long size)

closeSessionAsync

void closeSessionAsync(AMQSessionModel<?> session,
                       AMQConstant cause,
                       String message)

getRemoteSocketAddress

SocketAddress getRemoteSocketAddress()

block

void block()

unblock

void unblock()

pushScheduler

void pushScheduler(NetworkConnectionScheduler networkConnectionScheduler)

popScheduler

NetworkConnectionScheduler popScheduler()

hasSessionWithName

boolean hasSessionWithName(byte[] name)

sendConnectionCloseAsync

void sendConnectionCloseAsync(AMQConstant connectionForced,
                              String reason)

reserveOutboundMessageSpace

void reserveOutboundMessageSpace(long size)

isIOThread

boolean isIOThread()

stopConnection

void stopConnection()

getSessionModels

List<? extends AMQSessionModel<?>> getSessionModels()

resetStatistics

void resetStatistics()