org.apache.qpid.server.handler
Class BasicGetMethodHandler.GetNoAckSubscription
java.lang.Object
org.apache.qpid.server.subscription.SubscriptionImpl
org.apache.qpid.server.subscription.SubscriptionImpl.NoAckSubscription
org.apache.qpid.server.handler.BasicGetMethodHandler.GetNoAckSubscription
- All Implemented Interfaces:
- ConfiguredObject<SubscriptionConfigType,SubscriptionConfig>, SubscriptionConfig, FlowCreditManager.FlowCreditManagerListener, Subscription
- Enclosing class:
- BasicGetMethodHandler
public static final class BasicGetMethodHandler.GetNoAckSubscription
- extends SubscriptionImpl.NoAckSubscription
Methods inherited from class org.apache.qpid.server.subscription.SubscriptionImpl |
acquires, close, confirmAutoClose, creditStateChanged, filtersMessages, get, getArguments, getAssignedState, getChannel, getConfigStore, getConfigType, getConsumerTag, getCreateTime, getCreditManager, getCreditMode, getDelivered, getId, getLogActor, getName, getOwningState, getParent, getProtocolSession, getQueue, getQueueContext, getSendLock, getSessionConfig, getState, getSubscriptionID, hasInterest, isActive, isAutoClose, isBrowsing, isClosed, isDurable, isExclusive, isSessionTransactional, isSuspended, onDequeue, queueDeleted, recordMessageDelivery, releaseSendLock, restoreCredit, seesRequeues, sendToClient, set, setNoLocal, setQueue, setQueueContext, setStateListener, toString |
BasicGetMethodHandler.GetNoAckSubscription
public BasicGetMethodHandler.GetNoAckSubscription(AMQChannel channel,
AMQProtocolSession protocolSession,
org.apache.qpid.framing.AMQShortString consumerTag,
org.apache.qpid.framing.FieldTable filters,
boolean noLocal,
FlowCreditManager creditManager,
ClientDeliveryMethod deliveryMethod,
RecordDeliveryMethod recordMethod)
throws org.apache.qpid.AMQException
- Throws:
org.apache.qpid.AMQException
isTransient
public boolean isTransient()
- Specified by:
isTransient
in interface Subscription
- Overrides:
isTransient
in class SubscriptionImpl
wouldSuspend
public boolean wouldSuspend(QueueEntry msg)
- Specified by:
wouldSuspend
in interface Subscription
- Overrides:
wouldSuspend
in class SubscriptionImpl.NoAckSubscription
Licensed to the Apache Software Foundation