org.apache.qpid.server.model.adapter

Class SessionAdapter

java.lang.Object

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

org.apache.qpid.server.model.adapter.SessionAdapter

All Implemented Interfaces:

ConfiguredObject<SessionAdapter>, Session<SessionAdapter>

public final class SessionAdapter
extends AbstractConfiguredObject<SessionAdapter>
implements Session<SessionAdapter>

Nested Class Summary

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.Session

CHANNEL_ID, PRODUCER_FLOW_BLOCKED

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, STATE, TYPE

Constructor Summary

Constructors

Constructor and Description
SessionAdapter(AbstractAMQPConnection<?> connectionAdapter, AMQSessionModel session)

Method Summary

Modifier and Type	Method and Description
int	getChannelId()
<C extends ConfiguredObject> Collection<C>	getChildren(Class<C> clazz) Return children of the ConfiguredObject of the given class
long	getConsumerCount()
Collection<Consumer>	getConsumers()
long	getLocalTransactionBegins()
int	getLocalTransactionOpen()
long	getLocalTransactionRollbacks()
Collection<Publisher>	getPublishers()
long	getTransactionStartTime() Return the time the current transaction started.
long	getTransactionUpdateTime() Return the time of the last activity on the current transaction.
long	getUnacknowledgedMessages()
boolean	isProducerFlowBlocked()

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

addChangeListener, addChildAsync, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, beforeClose, 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, getChildExecutor, 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, onOpen, onResolve, onValidate, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, toString, 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, getChildExecutor, 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

SessionAdapter

public SessionAdapter(AbstractAMQPConnection<?> connectionAdapter,
                      AMQSessionModel session)

Method Detail

getChannelId

public int getChannelId()

Specified by:

getChannelId in interface Session<SessionAdapter>

isProducerFlowBlocked

public boolean isProducerFlowBlocked()

Specified by:

isProducerFlowBlocked in interface Session<SessionAdapter>

getConsumers

public Collection<Consumer> getConsumers()

Specified by:

getConsumers in interface Session<SessionAdapter>

getPublishers

public Collection<Publisher> getPublishers()

Specified by:

getPublishers in interface Session<SessionAdapter>

getChildren

public <C extends ConfiguredObject> Collection<C> getChildren(Class<C> clazz)

Description copied from interface: ConfiguredObject

Return children of the ConfiguredObject of the given class

Specified by:

getChildren in interface ConfiguredObject<SessionAdapter>

Overrides:

getChildren in class AbstractConfiguredObject<SessionAdapter>

Parameters:

clazz - the class of the children to return

Returns:

the children

getConsumerCount

public long getConsumerCount()

Specified by:

getConsumerCount in interface Session<SessionAdapter>

getLocalTransactionBegins

public long getLocalTransactionBegins()

Specified by:

getLocalTransactionBegins in interface Session<SessionAdapter>

getLocalTransactionOpen

public int getLocalTransactionOpen()

Specified by:

getLocalTransactionOpen in interface Session<SessionAdapter>

getLocalTransactionRollbacks

public long getLocalTransactionRollbacks()

Specified by:

getLocalTransactionRollbacks in interface Session<SessionAdapter>

getUnacknowledgedMessages

public long getUnacknowledgedMessages()

Specified by:

getUnacknowledgedMessages in interface Session<SessionAdapter>

getTransactionStartTime

public long getTransactionStartTime()

Description copied from interface: Session

Return the time the current transaction started.

Specified by:

getTransactionStartTime in interface Session<SessionAdapter>

Returns:

the time this transaction started or 0 if not in a transaction

getTransactionUpdateTime

public long getTransactionUpdateTime()

Description copied from interface: Session

Return the time of the last activity on the current transaction.

Specified by:

getTransactionUpdateTime in interface Session<SessionAdapter>

Returns:

the time of the last activity or 0 if not in a transaction