public class AMQPConnection_0_10 extends AbstractAMQPConnection<AMQPConnection_0_10>
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_10(Broker<?> broker,
ServerNetworkConnection network,
AmqpPort<?> port,
Transport transport,
long id,
AggregateTicker aggregateTicker) |
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() |
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
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
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_10(Broker<?> broker, ServerNetworkConnection network, AmqpPort<?> port, Transport transport, long id, AggregateTicker aggregateTicker)
public void received(QpidByteBuffer buf)
public void encryptedTransport()
public void writerIdle()
public void readerIdle()
public String getAddress()
public void closed()
protected void performDeleteTasks()
performDeleteTasks
in class AbstractAMQPConnection<AMQPConnection_0_10>
public boolean isTransportBlockedForWriting()
public void setTransportBlockedForWriting(boolean blocked)
public boolean hasWork()
public void notifyWork()
public void clearWork()
public void setWorkListener(Action<ProtocolEngine> listener)
public boolean hasSessionWithName(byte[] name)
public void sendConnectionCloseAsync(AMQConstant cause, String message)
public Principal getAuthorizedPrincipal()
public void closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)
public void block()
public String getRemoteContainerName()
public List<ServerSession> getSessionModels()
public void unblock()
public long getSessionCountLimit()
protected EventLogger getEventLogger()
getEventLogger
in class AbstractAMQPConnection<AMQPConnection_0_10>
public void logConnectionOpen()
logConnectionOpen
in class AbstractAMQPConnection<AMQPConnection_0_10>
public void initialiseHeartbeating(long writerDelay, long readerDelay)
initialiseHeartbeating
in class AbstractAMQPConnection<AMQPConnection_0_10>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.