org.apache.qpid.server.protocol.v0_8

Class AMQPConnection_0_8

java.lang.Object

org.apache.qpid.server.model.AbstractConfiguredObject<C>

org.apache.qpid.server.transport.AbstractAMQPConnection<AMQPConnection_0_8>

org.apache.qpid.server.protocol.v0_8.AMQPConnection_0_8

All Implemented Interfaces:

MethodProcessor<ServerChannelMethodProcessor>, ServerMethodProcessor<ServerChannelMethodProcessor>, ConfiguredObject<AMQPConnection_0_8>, Connection<AMQPConnection_0_8>, AMQPConnection<AMQPConnection_0_8>, ProtocolEngine, Deletable<AMQPConnection_0_8>, TransportActivity

public class AMQPConnection_0_8
extends AbstractAMQPConnection<AMQPConnection_0_8>
implements ServerMethodProcessor<ServerChannelMethodProcessor>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	AMQPConnection_0_8.WriteDeliverMethod

Nested classes/interfaces inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException

Field Summary

Fields inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

SECURED_STRING_VALUE

Fields inherited from interface org.apache.qpid.server.model.Connection

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

Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject

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 Summary

Constructors

Constructor and Description
AMQPConnection_0_8(Broker<?> broker, ServerNetworkConnection network, AmqpPort<?> port, Transport transport, Protocol protocol, long connectionId, AggregateTicker aggregateTicker)

Method Summary

Modifier and Type	Method and Description
void	block()
boolean	channelAwaitingClosure(int channelId)
void	clearWork()
void	closeChannel(int channelId, AMQConstant cause, String message)
void	closeChannelAndWriteFrame(AMQChannel channel, AMQConstant cause, String message)
void	closeChannelOk(int channelId)
void	closed()
void	closeNetworkConnection()
void	closeSessionAsync(AMQSessionModel<?> session, AMQConstant cause, String message)
ClientDeliveryMethod	createDeliveryMethod(int channelId)
void	encryptedTransport()
String	getAddress()
Principal	getAuthorizedPrincipal()
Subject	getAuthorizedSubject()
int	getBinaryDataLimit()
AMQChannel	getChannel(int channelId)
ServerChannelMethodProcessor	getChannelMethodProcessor(int channelId)
EventLogger	getEventLogger()
long	getMaxFrameSize()
long	getMaximumNumberOfChannels()
long	getMaxMessageSize()
int	getMessageCompressionThreshold()
MethodRegistry	getMethodRegistry()
Principal	getPeerPrincipal()
byte	getProtocolMajorVersion()
byte	getProtocolMinorVersion()
ProtocolOutputConverter	getProtocolOutputConverter()
ProtocolVersion	getProtocolVersion()
Object	getReference()
MethodRegistry	getRegistry()
String	getRemoteContainerName()
long	getSessionCountLimit()
List<AMQChannel>	getSessionModels()
boolean	hasSessionWithName(byte[] name)
boolean	hasWork()
boolean	ignoreAllButCloseOk()
boolean	isCloseWhenNoRoute()
boolean	isClosing()
boolean	isCompressionSupported()
boolean	isSendQueueDeleteOkRegardless()
boolean	isTransportBlockedForWriting()
void	notifyWork()
Iterator<Runnable>	processPendingIterator()
void	readerIdle()
void	receiveChannelOpen(int channelId)
void	receiveConnectionClose(int replyCode, AMQShortString replyText, int classId, int methodId)
void	receiveConnectionCloseOk()
void	receiveConnectionOpen(AMQShortString virtualHostName, AMQShortString capabilities, boolean insist)
void	receiveConnectionSecureOk(byte[] response)
void	receiveConnectionStartOk(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
void	receiveConnectionTuneOk(int channelMax, long frameMax, int heartbeat)
void	received(QpidByteBuffer msg)
void	receiveHeartbeat()
void	receiveProtocolHeader(ProtocolInitiation protocolInitiation)
void	sendConnectionCloseAsync(AMQConstant cause, String message)
void	setAuthorizedSubject(Subject authorizedSubject)
void	setCurrentMethod(int classId, int methodId)
void	setDeferFlush(boolean deferFlush)
void	setMaxFrameSize(int frameMax)
void	setTransportBlockedForWriting(boolean blocked)
void	setVirtualHost(VirtualHostImpl<?,?,?> virtualHost)
void	setWorkListener(Action<ProtocolEngine> listener)
String	toString()
void	unblock()
void	writeFrame(AMQDataBlock frame)
void	writerIdle()

Methods inherited from class org.apache.qpid.server.transport.AbstractAMQPConnection

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

Methods inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.server.model.ConfiguredObject

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

Constructor Detail

AMQPConnection_0_8

public AMQPConnection_0_8(Broker<?> broker,
                          ServerNetworkConnection network,
                          AmqpPort<?> port,
                          Transport transport,
                          Protocol protocol,
                          long connectionId,
                          AggregateTicker aggregateTicker)

Method Detail

isTransportBlockedForWriting

public boolean isTransportBlockedForWriting()

Specified by:

isTransportBlockedForWriting in interface ProtocolEngine

setTransportBlockedForWriting

public void setTransportBlockedForWriting(boolean blocked)

Specified by:

setTransportBlockedForWriting in interface ProtocolEngine

setMaxFrameSize

public void setMaxFrameSize(int frameMax)

getMaxFrameSize

public long getMaxFrameSize()

isClosing

public boolean isClosing()

createDeliveryMethod

public ClientDeliveryMethod createDeliveryMethod(int channelId)

received

public void received(QpidByteBuffer msg)

Specified by:

received in interface ProtocolEngine

writeFrame

public void writeFrame(AMQDataBlock frame)

getChannel

public AMQChannel getChannel(int channelId)

channelAwaitingClosure

public boolean channelAwaitingClosure(int channelId)

getMaximumNumberOfChannels

public long getMaximumNumberOfChannels()

closeChannelAndWriteFrame

public void closeChannelAndWriteFrame(AMQChannel channel,
                                      AMQConstant cause,
                                      String message)

closeChannel

public void closeChannel(int channelId,
                         AMQConstant cause,
                         String message)

closeChannelOk

public void closeChannelOk(int channelId)

closeNetworkConnection

public void closeNetworkConnection()

toString

public String toString()

Overrides:

toString in class AbstractConfiguredObject<AMQPConnection_0_8>

isSendQueueDeleteOkRegardless

public boolean isSendQueueDeleteOkRegardless()

getProtocolMajorVersion

public byte getProtocolMajorVersion()

getProtocolVersion

public ProtocolVersion getProtocolVersion()

Specified by:

getProtocolVersion in interface MethodProcessor<ServerChannelMethodProcessor>

getProtocolMinorVersion

public byte getProtocolMinorVersion()

getRegistry

public MethodRegistry getRegistry()

setVirtualHost

public void setVirtualHost(VirtualHostImpl<?,?,?> virtualHost)

getProtocolOutputConverter

public ProtocolOutputConverter getProtocolOutputConverter()

setAuthorizedSubject

public void setAuthorizedSubject(Subject authorizedSubject)

getAuthorizedSubject

public Subject getAuthorizedSubject()

getAuthorizedPrincipal

public Principal getAuthorizedPrincipal()

Specified by:

getAuthorizedPrincipal in interface AMQPConnection<AMQPConnection_0_8>

getPeerPrincipal

public Principal getPeerPrincipal()

getMethodRegistry

public MethodRegistry getMethodRegistry()

closed

public void closed()

Specified by:

closed in interface ProtocolEngine

encryptedTransport

public void encryptedTransport()

Specified by:

encryptedTransport in interface ProtocolEngine

readerIdle

public void readerIdle()

Specified by:

readerIdle in interface ProtocolEngine

Specified by:

readerIdle in interface TransportActivity

writerIdle

public void writerIdle()

Specified by:

writerIdle in interface ProtocolEngine

Specified by:

writerIdle in interface TransportActivity

getSessionCountLimit

public long getSessionCountLimit()

Specified by:

getSessionCountLimit in interface Connection<AMQPConnection_0_8>

getAddress

public String getAddress()

closeSessionAsync

public void closeSessionAsync(AMQSessionModel<?> session,
                              AMQConstant cause,
                              String message)

Specified by:

closeSessionAsync in interface AMQPConnection<AMQPConnection_0_8>

sendConnectionCloseAsync

public void sendConnectionCloseAsync(AMQConstant cause,
                                     String message)

Specified by:

sendConnectionCloseAsync in interface AMQPConnection<AMQPConnection_0_8>

block

public void block()

Specified by:

block in interface AMQPConnection<AMQPConnection_0_8>

unblock

public void unblock()

Specified by:

unblock in interface AMQPConnection<AMQPConnection_0_8>

getSessionModels

public List<AMQChannel> getSessionModels()

Specified by:

getSessionModels in interface AMQPConnection<AMQPConnection_0_8>

getRemoteContainerName

public String getRemoteContainerName()

Specified by:

getRemoteContainerName in interface AMQPConnection<AMQPConnection_0_8>

setDeferFlush

public void setDeferFlush(boolean deferFlush)

hasSessionWithName

public boolean hasSessionWithName(byte[] name)

Specified by:

hasSessionWithName in interface AMQPConnection<AMQPConnection_0_8>

receiveChannelOpen

public void receiveChannelOpen(int channelId)

Specified by:

receiveChannelOpen in interface ServerMethodProcessor<ServerChannelMethodProcessor>

receiveConnectionOpen

public void receiveConnectionOpen(AMQShortString virtualHostName,
                                  AMQShortString capabilities,
                                  boolean insist)

Specified by:

receiveConnectionOpen in interface ServerMethodProcessor<ServerChannelMethodProcessor>

receiveConnectionClose

public void receiveConnectionClose(int replyCode,
                                   AMQShortString replyText,
                                   int classId,
                                   int methodId)

Specified by:

receiveConnectionClose in interface MethodProcessor<ServerChannelMethodProcessor>

receiveConnectionCloseOk

public void receiveConnectionCloseOk()

Specified by:

receiveConnectionCloseOk in interface MethodProcessor<ServerChannelMethodProcessor>

receiveConnectionSecureOk

public void receiveConnectionSecureOk(byte[] response)

Specified by:

receiveConnectionSecureOk in interface ServerMethodProcessor<ServerChannelMethodProcessor>

receiveConnectionStartOk

public void receiveConnectionStartOk(FieldTable clientProperties,
                                     AMQShortString mechanism,
                                     byte[] response,
                                     AMQShortString locale)

Specified by:

receiveConnectionStartOk in interface ServerMethodProcessor<ServerChannelMethodProcessor>

receiveConnectionTuneOk

public void receiveConnectionTuneOk(int channelMax,
                                    long frameMax,
                                    int heartbeat)

Specified by:

receiveConnectionTuneOk in interface ServerMethodProcessor<ServerChannelMethodProcessor>

getBinaryDataLimit

public int getBinaryDataLimit()

getMaxMessageSize

public long getMaxMessageSize()

getReference

public Object getReference()

isCloseWhenNoRoute

public boolean isCloseWhenNoRoute()

isCompressionSupported

public boolean isCompressionSupported()

getMessageCompressionThreshold

public int getMessageCompressionThreshold()

getEventLogger

public EventLogger getEventLogger()

Specified by:

getEventLogger in class AbstractAMQPConnection<AMQPConnection_0_8>

getChannelMethodProcessor

public ServerChannelMethodProcessor getChannelMethodProcessor(int channelId)

Specified by:

getChannelMethodProcessor in interface MethodProcessor<ServerChannelMethodProcessor>

receiveHeartbeat

public void receiveHeartbeat()

Specified by:

receiveHeartbeat in interface MethodProcessor<ServerChannelMethodProcessor>

receiveProtocolHeader

public void receiveProtocolHeader(ProtocolInitiation protocolInitiation)

Specified by:

receiveProtocolHeader in interface MethodProcessor<ServerChannelMethodProcessor>

setCurrentMethod

public void setCurrentMethod(int classId,
                             int methodId)

Specified by:

setCurrentMethod in interface MethodProcessor<ServerChannelMethodProcessor>

ignoreAllButCloseOk

public boolean ignoreAllButCloseOk()

Specified by:

ignoreAllButCloseOk in interface MethodProcessor<ServerChannelMethodProcessor>

hasWork

public boolean hasWork()

Specified by:

hasWork in interface ProtocolEngine

notifyWork

public void notifyWork()

Specified by:

notifyWork in interface AMQPConnection<AMQPConnection_0_8>

Specified by:

notifyWork in interface ProtocolEngine

clearWork

public void clearWork()

Specified by:

clearWork in interface ProtocolEngine

setWorkListener

public void setWorkListener(Action<ProtocolEngine> listener)

Specified by:

setWorkListener in interface ProtocolEngine

processPendingIterator

public Iterator<Runnable> processPendingIterator()

Specified by:

processPendingIterator in interface ProtocolEngine