public class AMQPConnection_1_0 extends AbstractAMQPConnection<AMQPConnection_1_0> implements FrameOutputHandler
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
Modifier and Type | Field and Description |
---|---|
static long |
CLOSE_RESPONSE_TIMEOUT |
static org.slf4j.Logger |
LOGGER |
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_1_0(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker,
boolean useSASL) |
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, logConnectionOpen, markTransportClosed, onOpen, 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, 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
addChangeListener, asObjectRecord, 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 static org.slf4j.Logger LOGGER
public static final long CLOSE_RESPONSE_TIMEOUT
public AMQPConnection_1_0(Broker<?> broker, ServerNetworkConnection network, AmqpPort<?> port, Transport transport, long id, AggregateTicker aggregateTicker, boolean useSASL)
public ByteBufferSender getSender()
public ByteBuffer initiateNonSasl(List<String> mechanisms)
public ByteBuffer initiateSasl()
public void writerIdle()
writerIdle
in interface ProtocolEngine
writerIdle
in interface TransportActivity
public void readerIdle()
readerIdle
in interface ProtocolEngine
readerIdle
in interface TransportActivity
public void encryptedTransport()
encryptedTransport
in interface ProtocolEngine
public String getAddress()
public void received(QpidByteBuffer msg)
received
in interface ProtocolEngine
public void closed()
closed
in interface ProtocolEngine
public boolean canSend()
canSend
in interface FrameOutputHandler
public void send(AMQFrame amqFrame)
send
in interface FrameOutputHandler
public void send(AMQFrame amqFrame, ByteBuffer buf)
send
in interface FrameOutputHandler
public void send(short channel, FrameBody body)
protected void performDeleteTasks()
performDeleteTasks
in class AbstractAMQPConnection<AMQPConnection_1_0>
public void close()
close
in interface FrameOutputHandler
close
in interface ConfiguredObject<AMQPConnection_1_0>
close
in class AbstractConfiguredObject<AMQPConnection_1_0>
public boolean isTransportBlockedForWriting()
isTransportBlockedForWriting
in interface ProtocolEngine
public void setTransportBlockedForWriting(boolean blocked)
setTransportBlockedForWriting
in interface ProtocolEngine
public Iterator<Runnable> processPendingIterator()
processPendingIterator
in interface ProtocolEngine
public boolean hasWork()
hasWork
in interface ProtocolEngine
public void notifyWork()
notifyWork
in interface AMQPConnection<AMQPConnection_1_0>
notifyWork
in interface ProtocolEngine
public void clearWork()
clearWork
in interface ProtocolEngine
public void setWorkListener(Action<ProtocolEngine> listener)
setWorkListener
in interface ProtocolEngine
public boolean hasSessionWithName(byte[] name)
hasSessionWithName
in interface AMQPConnection<AMQPConnection_1_0>
public void sendConnectionCloseAsync(AMQConstant cause, String message)
sendConnectionCloseAsync
in interface AMQPConnection<AMQPConnection_1_0>
public Principal getAuthorizedPrincipal()
getAuthorizedPrincipal
in interface AMQPConnection<AMQPConnection_1_0>
public void closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)
closeSessionAsync
in interface AMQPConnection<AMQPConnection_1_0>
public void block()
block
in interface AMQPConnection<AMQPConnection_1_0>
public String getRemoteContainerName()
getRemoteContainerName
in interface AMQPConnection<AMQPConnection_1_0>
public List<Session_1_0> getSessionModels()
getSessionModels
in interface AMQPConnection<AMQPConnection_1_0>
public void unblock()
unblock
in interface AMQPConnection<AMQPConnection_1_0>
public long getSessionCountLimit()
getSessionCountLimit
in interface Connection<AMQPConnection_1_0>
protected EventLogger getEventLogger()
getEventLogger
in class AbstractAMQPConnection<AMQPConnection_1_0>
public void initialiseHeartbeating(long writerDelay, long readerDelay)
initialiseHeartbeating
in class AbstractAMQPConnection<AMQPConnection_1_0>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.