public abstract class AbstractAMQPConnection<C extends AbstractAMQPConnection<C>> extends AbstractConfiguredObject<C> implements ProtocolEngine, AMQPConnection<C>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameExceptionSECURED_STRING_VALUECLIENT_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, TRANSPORTCONTEXT, 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 and Description |
|---|
AbstractAMQPConnection(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
Protocol protocol,
long connectionId,
AggregateTicker aggregateTicker) |
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, validateOnCreateclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitclearWork, closed, encryptedTransport, hasWork, isTransportBlockedForWriting, notifyWork, processPendingIterator, readerIdle, received, setTransportBlockedForWriting, setWorkListener, writerIdleblock, closeSessionAsync, getAuthorizedPrincipal, getRemoteContainerName, getSessionModels, hasSessionWithName, notifyWork, sendConnectionCloseAsync, unblockgetSessionCountLimitaddChangeListener, 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, setAttributesAsyncpublic AbstractAMQPConnection(Broker<?> broker, ServerNetworkConnection network, AmqpPort<?> port, Transport transport, Protocol protocol, long connectionId, AggregateTicker aggregateTicker)
protected void onOpen()
onOpen in class AbstractConfiguredObject<C extends AbstractAMQPConnection<C>>public Broker<?> getBroker()
public final ServerNetworkConnection getNetwork()
public final AmqpPort<?> getPort()
getPort in interface Connection<C extends AbstractAMQPConnection<C>>public final Transport getTransport()
getTransport in interface Connection<C extends AbstractAMQPConnection<C>>public String getTransportInfo()
getTransportInfo in interface Connection<C extends AbstractAMQPConnection<C>>public Protocol getProtocol()
getProtocol in interface Connection<C extends AbstractAMQPConnection<C>>public final AggregateTicker getAggregateTicker()
getAggregateTicker in interface ProtocolEnginepublic final long getLastIoTime()
getLastIoTime in interface Connection<C extends AbstractAMQPConnection<C>>public final long getLastReadTime()
getLastReadTime in interface TransportActivitypublic final void updateLastReadTime()
public final long getLastWriteTime()
getLastWriteTime in interface TransportActivitypublic final void updateLastWriteTime()
public final long getConnectionId()
getConnectionId in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public final StatisticsCounter getMessageDeliveryStatistics()
public String getRemoteAddressString()
getRemoteAddressString in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public final void stopConnection()
stopConnection in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public final ProtocolEngine getProtocolEngine()
public boolean isConnectionStopped()
isConnectionStopped in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public final String getVirtualHostName()
getVirtualHostName in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public String getClientVersion()
getClientVersion in interface Connection<C extends AbstractAMQPConnection<C>>public String getRemoteProcessPid()
getRemoteProcessPid in interface Connection<C extends AbstractAMQPConnection<C>>public void pushScheduler(NetworkConnectionScheduler networkConnectionScheduler)
pushScheduler in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public NetworkConnectionScheduler popScheduler()
popScheduler in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public String getClientProduct()
public void addDeleteTask(Action<? super C> task)
addDeleteTask in interface Deletable<C extends AbstractAMQPConnection<C>>public void removeDeleteTask(Action<? super C> task)
removeDeleteTask in interface Deletable<C extends AbstractAMQPConnection<C>>protected void performDeleteTasks()
public String getClientId()
getClientId in interface Connection<C extends AbstractAMQPConnection<C>>public final StatisticsCounter getDataReceiptStatistics()
public final StatisticsCounter getDataDeliveryStatistics()
public final SocketAddress getRemoteSocketAddress()
getRemoteSocketAddress in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public void registerMessageDelivered(long messageSize)
registerMessageDelivered in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public void registerMessageReceived(long messageSize,
long timestamp)
registerMessageReceived in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public final void resetStatistics()
resetStatistics in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public final StatisticsCounter getMessageReceiptStatistics()
public void setClientProduct(String clientProduct)
public void setClientVersion(String clientVersion)
public void setRemoteProcessPid(String remoteProcessPid)
public void setClientId(String clientId)
public boolean isMessageAssignmentSuspended()
isMessageAssignmentSuspended in interface AMQPConnection<C extends AbstractAMQPConnection<C>>isMessageAssignmentSuspended in interface ProtocolEnginepublic void setMessageAssignmentSuspended(boolean messageAssignmentSuspended,
boolean notifyConsumers)
setMessageAssignmentSuspended in interface ProtocolEnginepublic void alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread(boolean allowed)
alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread in interface AMQPConnection<C extends AbstractAMQPConnection<C>>public void setIOThread(Thread ioThread)
setIOThread in interface ProtocolEnginepublic boolean isIOThread()
isIOThread in interface AMQPConnection<C extends AbstractAMQPConnection<C>>protected <T> T runAsSubject(PrivilegedAction<T> action)
public Subject getSubject()
getSubject in interface ProtocolEnginepublic void sessionAdded(AMQSessionModel<?> session)
public void sessionRemoved(AMQSessionModel<?> session)
public final void associateVirtualHost(VirtualHost<?,?,?> virtualHost)
public TaskExecutor getChildExecutor()
getChildExecutor in interface ConfiguredObject<C extends AbstractAMQPConnection<C>>getChildExecutor in class AbstractConfiguredObject<C extends AbstractAMQPConnection<C>>public boolean isIncoming()
isIncoming in interface Connection<C extends AbstractAMQPConnection<C>>public String getLocalAddress()
getLocalAddress in interface Connection<C extends AbstractAMQPConnection<C>>public String getPrincipal()
getPrincipal in interface Connection<C extends AbstractAMQPConnection<C>>public String getRemoteAddress()
getRemoteAddress in interface Connection<C extends AbstractAMQPConnection<C>>public String getRemoteProcessName()
getRemoteProcessName in interface Connection<C extends AbstractAMQPConnection<C>>public Collection<Session> getSessions()
getSessions in interface Connection<C extends AbstractAMQPConnection<C>>protected com.google.common.util.concurrent.ListenableFuture<Void> beforeClose()
beforeClose in class AbstractConfiguredObject<C extends AbstractAMQPConnection<C>>public <C extends ConfiguredObject> com.google.common.util.concurrent.ListenableFuture<C> addChildAsync(Class<C> childClass, Map<String,Object> attributes, ConfiguredObject... otherParents)
addChildAsync in class AbstractConfiguredObject<C extends AbstractAMQPConnection<C>>public long getBytesIn()
getBytesIn in interface Connection<C extends AbstractAMQPConnection<C>>public long getBytesOut()
getBytesOut in interface Connection<C extends AbstractAMQPConnection<C>>public long getMessagesIn()
getMessagesIn in interface Connection<C extends AbstractAMQPConnection<C>>public long getMessagesOut()
getMessagesOut in interface Connection<C extends AbstractAMQPConnection<C>>public AccessControlContext getAccessControllerContext()
public final void updateAccessControllerContext()
protected void logConnectionOpen()
public int getSessionCount()
getSessionCount in interface Connection<C extends AbstractAMQPConnection<C>>protected void initialiseHeartbeating(long writerDelay,
long readerDelay)
public AMQPConnection<?> getUnderlyingConnection()
getUnderlyingConnection in interface Connection<C extends AbstractAMQPConnection<C>>public void reserveOutboundMessageSpace(long size)
reserveOutboundMessageSpace in interface AMQPConnection<C extends AbstractAMQPConnection<C>>protected void markTransportClosed()
public LogSubject getLogSubject()
protected abstract EventLogger getEventLogger()
public VirtualHost<?,?,?> getVirtualHost()
getVirtualHost in interface Connection<C extends AbstractAMQPConnection<C>>Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.