org.apache.qpid.server.protocol.v0_10

Class AMQPConnection_0_10

java.lang.Object

org.apache.qpid.server.model.AbstractConfiguredObject<C>

org.apache.qpid.server.transport.AbstractAMQPConnection<AMQPConnection_0_10>

org.apache.qpid.server.protocol.v0_10.AMQPConnection_0_10

All Implemented Interfaces:

ConfiguredObject<AMQPConnection_0_10>, Connection<AMQPConnection_0_10>, AMQPConnection<AMQPConnection_0_10>, ProtocolEngine, Deletable<AMQPConnection_0_10>, TransportActivity

public class AMQPConnection_0_10
extends AbstractAMQPConnection<AMQPConnection_0_10>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException

Field Summary

Fields inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

SECURED_STRING_VALUE

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

Constructor Summary

Constructors

Constructor and Description
AMQPConnection_0_10(Broker<?> broker, ServerNetworkConnection network, AmqpPort<?> port, Transport transport, long id, AggregateTicker aggregateTicker)

Method Summary

Modifier and Type	Method and Description
void	block()
void	clearWork()
void	closed()
void	closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)
void	encryptedTransport()
String	getAddress()
Principal	getAuthorizedPrincipal()
protected EventLogger	getEventLogger()
String	getRemoteContainerName()
long	getSessionCountLimit()
List<ServerSession>	getSessionModels()
boolean	hasSessionWithName(byte[] name)
boolean	hasWork()
void	initialiseHeartbeating(long writerDelay, long readerDelay)
boolean	isTransportBlockedForWriting()
void	logConnectionOpen()
void	notifyWork()
protected void	performDeleteTasks()
Iterator<Runnable>	processPendingIterator()
void	readerIdle()
void	received(QpidByteBuffer buf)
void	sendConnectionCloseAsync(AMQConstant cause, String message)
void	setTransportBlockedForWriting(boolean blocked)
void	setWorkListener(Action<ProtocolEngine> listener)
void	unblock()
void	writerIdle()

Methods inherited from class org.apache.qpid.server.transport.AbstractAMQPConnection

addChildAsync, addDeleteTask, alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread, associateVirtualHost, beforeClose, getAccessControllerContext, getAggregateTicker, getBroker, getBytesIn, getBytesOut, getChildExecutor, getClientId, getClientProduct, getClientVersion, getConnectionId, getDataDeliveryStatistics, getDataReceiptStatistics, getLastIoTime, getLastReadTime, getLastWriteTime, getLocalAddress, getLogSubject, getMessageDeliveryStatistics, getMessageReceiptStatistics, getMessagesIn, getMessagesOut, getNetwork, getPort, getPrincipal, getProtocol, getProtocolEngine, getRemoteAddress, getRemoteAddressString, getRemoteProcessName, getRemoteProcessPid, getRemoteSocketAddress, getSessionCount, getSessions, getSubject, getTransport, getTransportInfo, getUnderlyingConnection, getVirtualHost, getVirtualHostName, isConnectionStopped, isIncoming, isIOThread, isMessageAssignmentSuspended, markTransportClosed, onOpen, popScheduler, pushScheduler, registerMessageDelivered, registerMessageReceived, removeDeleteTask, reserveOutboundMessageSpace, resetStatistics, runAsSubject, sessionAdded, sessionRemoved, setClientId, setClientProduct, setClientVersion, setIOThread, setMessageAssignmentSuspended, setRemoteProcessPid, stopConnection, updateAccessControllerContext, updateLastReadTime, updateLastWriteTime

Methods inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

addChangeListener, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, changeAttribute, changeAttributes, childAdded, childRemoved, close, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleted, doAfter, doAfter, doAfter, doAfter, doAfter, doAfter, doAfterAlways, doAfterAlways, doCreation, doOnConfigThread, doOpening, doResolution, doSync, doSync, doValidation, findConfiguredObject, forceUpdateAllSecureAttributes, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getSecurityManager, getState, getStatistics, getTaskExecutor, getType, getTypeClass, handleExceptionOnOpen, isDurable, managesChildStorage, notifyStateChanged, onClose, onCreate, onExceptionInOpen, onResolve, onValidate, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, toString, validateChange, validateOnCreate

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.model.ConfiguredObject

addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, 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

Constructor Detail

AMQPConnection_0_10

public AMQPConnection_0_10(Broker<?> broker,
                           ServerNetworkConnection network,
                           AmqpPort<?> port,
                           Transport transport,
                           long id,
                           AggregateTicker aggregateTicker)

Method Detail

received

public void received(QpidByteBuffer buf)

encryptedTransport

public void encryptedTransport()

writerIdle

public void writerIdle()

readerIdle

public void readerIdle()

getAddress

public String getAddress()

closed

public void closed()

performDeleteTasks

protected void performDeleteTasks()

Overrides:

performDeleteTasks in class AbstractAMQPConnection<AMQPConnection_0_10>

isTransportBlockedForWriting

public boolean isTransportBlockedForWriting()

setTransportBlockedForWriting

public void setTransportBlockedForWriting(boolean blocked)

processPendingIterator

public Iterator<Runnable> processPendingIterator()

hasWork

public boolean hasWork()

notifyWork

public void notifyWork()

clearWork

public void clearWork()

setWorkListener

public void setWorkListener(Action<ProtocolEngine> listener)

hasSessionWithName

public boolean hasSessionWithName(byte[] name)

sendConnectionCloseAsync

public void sendConnectionCloseAsync(AMQConstant cause,
                                     String message)

getAuthorizedPrincipal

public Principal getAuthorizedPrincipal()

closeSessionAsync

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

block

public void block()

getRemoteContainerName

public String getRemoteContainerName()

getSessionModels

public List<ServerSession> getSessionModels()

unblock

public void unblock()

getSessionCountLimit

public long getSessionCountLimit()

getEventLogger

protected EventLogger getEventLogger()

Specified by:

getEventLogger in class AbstractAMQPConnection<AMQPConnection_0_10>

logConnectionOpen

public void logConnectionOpen()

Overrides:

logConnectionOpen in class AbstractAMQPConnection<AMQPConnection_0_10>

initialiseHeartbeating

public void initialiseHeartbeating(long writerDelay,
                                   long readerDelay)

Overrides:

initialiseHeartbeating in class AbstractAMQPConnection<AMQPConnection_0_10>