public interface AMQPConnection<C extends AMQPConnection<C>> extends Connection<C>, Deletable<C>
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
getBytesIn, getBytesOut, getClientId, getClientVersion, getLastIoTime, getLocalAddress, getMessagesIn, getMessagesOut, getPort, getPrincipal, getProtocol, getRemoteAddress, getRemoteProcessName, getRemoteProcessPid, getSessionCount, getSessionCountLimit, getSessions, getTransport, getTransportInfo, getUnderlyingConnection, getVirtualHost, isIncoming
addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, 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
addDeleteTask, removeDeleteTask
boolean isMessageAssignmentSuspended()
void alwaysAllowMessageAssignmentInThisThreadIfItIsIOThread(boolean override)
long getConnectionId()
Principal getAuthorizedPrincipal()
String getRemoteAddressString()
String getVirtualHostName()
void notifyWork()
String getRemoteContainerName()
boolean isConnectionStopped()
void registerMessageReceived(long size, long arrivalTime)
void registerMessageDelivered(long size)
void closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)
SocketAddress getRemoteSocketAddress()
void block()
void unblock()
void pushScheduler(NetworkConnectionScheduler networkConnectionScheduler)
NetworkConnectionScheduler popScheduler()
boolean hasSessionWithName(byte[] name)
void sendConnectionCloseAsync(AMQConstant connectionForced, String reason)
void reserveOutboundMessageSpace(long size)
boolean isIOThread()
void stopConnection()
List<? extends AMQSessionModel<?>> getSessionModels()
void resetStatistics()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.