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.DuplicateNameException
SECURED_STRING_VALUE
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
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 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, validateOnCreate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
clearWork, closed, encryptedTransport, hasWork, isTransportBlockedForWriting, notifyWork, processPendingIterator, readerIdle, received, setTransportBlockedForWriting, setWorkListener, writerIdle
block, closeSessionAsync, getAuthorizedPrincipal, getRemoteContainerName, getSessionModels, hasSessionWithName, notifyWork, sendConnectionCloseAsync, unblock
getSessionCountLimit
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
public 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 ProtocolEngine
public final long getLastIoTime()
getLastIoTime
in interface Connection<C extends AbstractAMQPConnection<C>>
public final long getLastReadTime()
getLastReadTime
in interface TransportActivity
public final void updateLastReadTime()
public final long getLastWriteTime()
getLastWriteTime
in interface TransportActivity
public 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 ProtocolEngine
public void setMessageAssignmentSuspended(boolean messageAssignmentSuspended, boolean notifyConsumers)
setMessageAssignmentSuspended
in interface ProtocolEngine
public void alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread(boolean allowed)
alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread
in interface AMQPConnection<C extends AbstractAMQPConnection<C>>
public void setIOThread(Thread ioThread)
setIOThread
in interface ProtocolEngine
public boolean isIOThread()
isIOThread
in interface AMQPConnection<C extends AbstractAMQPConnection<C>>
protected <T> T runAsSubject(PrivilegedAction<T> action)
public Subject getSubject()
getSubject
in interface ProtocolEngine
public 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.