public class AMQPConnection_0_8 extends AbstractAMQPConnection<AMQPConnection_0_8> implements ServerMethodProcessor<ServerChannelMethodProcessor>
Modifier and Type | Class and Description |
---|---|
class |
AMQPConnection_0_8.WriteDeliverMethod |
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 |
---|
AMQPConnection_0_8(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
Protocol protocol,
long connectionId,
AggregateTicker aggregateTicker) |
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, initialiseHeartbeating, isConnectionStopped, isIncoming, isIOThread, isMessageAssignmentSuspended, logConnectionOpen, markTransportClosed, onOpen, performDeleteTasks, popScheduler, pushScheduler, registerMessageDelivered, registerMessageReceived, removeDeleteTask, reserveOutboundMessageSpace, resetStatistics, runAsSubject, sessionAdded, sessionRemoved, setClientId, setClientProduct, setClientVersion, setIOThread, setMessageAssignmentSuspended, setRemoteProcessPid, stopConnection, updateAccessControllerContext, updateLastReadTime, updateLastWriteTime
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, validateChange, validateOnCreate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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 AMQPConnection_0_8(Broker<?> broker, ServerNetworkConnection network, AmqpPort<?> port, Transport transport, Protocol protocol, long connectionId, AggregateTicker aggregateTicker)
public boolean isTransportBlockedForWriting()
isTransportBlockedForWriting
in interface ProtocolEngine
public void setTransportBlockedForWriting(boolean blocked)
setTransportBlockedForWriting
in interface ProtocolEngine
public void setMaxFrameSize(int frameMax)
public long getMaxFrameSize()
public boolean isClosing()
public ClientDeliveryMethod createDeliveryMethod(int channelId)
public void received(QpidByteBuffer msg)
received
in interface ProtocolEngine
public void writeFrame(AMQDataBlock frame)
public AMQChannel getChannel(int channelId)
public boolean channelAwaitingClosure(int channelId)
public long getMaximumNumberOfChannels()
public void closeChannelAndWriteFrame(AMQChannel channel, AMQConstant cause, String message)
public void closeChannel(int channelId, AMQConstant cause, String message)
public void closeChannelOk(int channelId)
public void closeNetworkConnection()
public String toString()
toString
in class AbstractConfiguredObject<AMQPConnection_0_8>
public boolean isSendQueueDeleteOkRegardless()
public byte getProtocolMajorVersion()
public ProtocolVersion getProtocolVersion()
getProtocolVersion
in interface MethodProcessor<ServerChannelMethodProcessor>
public byte getProtocolMinorVersion()
public MethodRegistry getRegistry()
public void setVirtualHost(VirtualHostImpl<?,?,?> virtualHost)
public ProtocolOutputConverter getProtocolOutputConverter()
public void setAuthorizedSubject(Subject authorizedSubject)
public Subject getAuthorizedSubject()
public Principal getAuthorizedPrincipal()
getAuthorizedPrincipal
in interface AMQPConnection<AMQPConnection_0_8>
public Principal getPeerPrincipal()
public MethodRegistry getMethodRegistry()
public void closed()
closed
in interface ProtocolEngine
public void encryptedTransport()
encryptedTransport
in interface ProtocolEngine
public void readerIdle()
readerIdle
in interface ProtocolEngine
readerIdle
in interface TransportActivity
public void writerIdle()
writerIdle
in interface ProtocolEngine
writerIdle
in interface TransportActivity
public long getSessionCountLimit()
getSessionCountLimit
in interface Connection<AMQPConnection_0_8>
public String getAddress()
public void closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)
closeSessionAsync
in interface AMQPConnection<AMQPConnection_0_8>
public void sendConnectionCloseAsync(AMQConstant cause, String message)
sendConnectionCloseAsync
in interface AMQPConnection<AMQPConnection_0_8>
public void block()
block
in interface AMQPConnection<AMQPConnection_0_8>
public void unblock()
unblock
in interface AMQPConnection<AMQPConnection_0_8>
public List<AMQChannel> getSessionModels()
getSessionModels
in interface AMQPConnection<AMQPConnection_0_8>
public String getRemoteContainerName()
getRemoteContainerName
in interface AMQPConnection<AMQPConnection_0_8>
public void setDeferFlush(boolean deferFlush)
public boolean hasSessionWithName(byte[] name)
hasSessionWithName
in interface AMQPConnection<AMQPConnection_0_8>
public void receiveChannelOpen(int channelId)
receiveChannelOpen
in interface ServerMethodProcessor<ServerChannelMethodProcessor>
public void receiveConnectionOpen(AMQShortString virtualHostName, AMQShortString capabilities, boolean insist)
receiveConnectionOpen
in interface ServerMethodProcessor<ServerChannelMethodProcessor>
public void receiveConnectionClose(int replyCode, AMQShortString replyText, int classId, int methodId)
receiveConnectionClose
in interface MethodProcessor<ServerChannelMethodProcessor>
public void receiveConnectionCloseOk()
receiveConnectionCloseOk
in interface MethodProcessor<ServerChannelMethodProcessor>
public void receiveConnectionSecureOk(byte[] response)
receiveConnectionSecureOk
in interface ServerMethodProcessor<ServerChannelMethodProcessor>
public void receiveConnectionStartOk(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
receiveConnectionStartOk
in interface ServerMethodProcessor<ServerChannelMethodProcessor>
public void receiveConnectionTuneOk(int channelMax, long frameMax, int heartbeat)
receiveConnectionTuneOk
in interface ServerMethodProcessor<ServerChannelMethodProcessor>
public int getBinaryDataLimit()
public long getMaxMessageSize()
public Object getReference()
public boolean isCloseWhenNoRoute()
public boolean isCompressionSupported()
public int getMessageCompressionThreshold()
public EventLogger getEventLogger()
getEventLogger
in class AbstractAMQPConnection<AMQPConnection_0_8>
public ServerChannelMethodProcessor getChannelMethodProcessor(int channelId)
getChannelMethodProcessor
in interface MethodProcessor<ServerChannelMethodProcessor>
public void receiveHeartbeat()
receiveHeartbeat
in interface MethodProcessor<ServerChannelMethodProcessor>
public void receiveProtocolHeader(ProtocolInitiation protocolInitiation)
receiveProtocolHeader
in interface MethodProcessor<ServerChannelMethodProcessor>
public void setCurrentMethod(int classId, int methodId)
setCurrentMethod
in interface MethodProcessor<ServerChannelMethodProcessor>
public boolean ignoreAllButCloseOk()
ignoreAllButCloseOk
in interface MethodProcessor<ServerChannelMethodProcessor>
public boolean hasWork()
hasWork
in interface ProtocolEngine
public void notifyWork()
notifyWork
in interface AMQPConnection<AMQPConnection_0_8>
notifyWork
in interface ProtocolEngine
public void clearWork()
clearWork
in interface ProtocolEngine
public void setWorkListener(Action<ProtocolEngine> listener)
setWorkListener
in interface ProtocolEngine
public Iterator<Runnable> processPendingIterator()
processPendingIterator
in interface ProtocolEngine
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.