public final class SessionAdapter extends AbstractConfiguredObject<SessionAdapter> implements Session<SessionAdapter>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
SECURED_STRING_VALUE
CHANNEL_ID, PRODUCER_FLOW_BLOCKED
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 and Description |
---|
SessionAdapter(AbstractAMQPConnection<?> connectionAdapter,
AMQSessionModel session) |
Modifier and Type | Method and Description |
---|---|
int |
getChannelId() |
<C extends ConfiguredObject> |
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() |
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
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, 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
public SessionAdapter(AbstractAMQPConnection<?> connectionAdapter, AMQSessionModel session)
public int getChannelId()
getChannelId
in interface Session<SessionAdapter>
public boolean isProducerFlowBlocked()
isProducerFlowBlocked
in interface Session<SessionAdapter>
public Collection<Consumer> getConsumers()
getConsumers
in interface Session<SessionAdapter>
public Collection<Publisher> getPublishers()
getPublishers
in interface Session<SessionAdapter>
public <C extends ConfiguredObject> Collection<C> getChildren(Class<C> clazz)
ConfiguredObject
getChildren
in interface ConfiguredObject<SessionAdapter>
getChildren
in class AbstractConfiguredObject<SessionAdapter>
clazz
- the class of the children to returnpublic long getConsumerCount()
getConsumerCount
in interface Session<SessionAdapter>
public long getLocalTransactionBegins()
getLocalTransactionBegins
in interface Session<SessionAdapter>
public int getLocalTransactionOpen()
getLocalTransactionOpen
in interface Session<SessionAdapter>
public long getLocalTransactionRollbacks()
getLocalTransactionRollbacks
in interface Session<SessionAdapter>
public long getUnacknowledgedMessages()
getUnacknowledgedMessages
in interface Session<SessionAdapter>
public long getTransactionStartTime()
Session
getTransactionStartTime
in interface Session<SessionAdapter>
public long getTransactionUpdateTime()
Session
getTransactionUpdateTime
in interface Session<SessionAdapter>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.