org.apache.qpid.server.handler
Class BasicGetMethodHandler.GetNoAckSubscription

java.lang.Object
  extended by org.apache.qpid.server.subscription.SubscriptionImpl
      extended by org.apache.qpid.server.subscription.SubscriptionImpl.NoAckSubscription
          extended by 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


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.server.subscription.SubscriptionImpl
SubscriptionImpl.NoAckSubscription
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.subscription.Subscription
Subscription.State, Subscription.StateListener
 
Constructor Summary
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)
           
 
Method Summary
 boolean isTransient()
           
 boolean wouldSuspend(QueueEntry msg)
           
 
Methods inherited from class org.apache.qpid.server.subscription.SubscriptionImpl.NoAckSubscription
isBrowser, isExplicitAcknowledge, send
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

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
Method Detail

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