org.apache.qpid.server.subscription
Class SubscriptionImpl.NoAckSubscription

java.lang.Object
  extended by org.apache.qpid.server.subscription.SubscriptionImpl
      extended by org.apache.qpid.server.subscription.SubscriptionImpl.NoAckSubscription
All Implemented Interfaces:
ConfiguredObject<SubscriptionConfigType,SubscriptionConfig>, SubscriptionConfig, FlowCreditManager.FlowCreditManagerListener, Subscription
Direct Known Subclasses:
BasicGetMethodHandler.GetNoAckSubscription
Enclosing class:
SubscriptionImpl

public static class SubscriptionImpl.NoAckSubscription
extends SubscriptionImpl


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.qpid.server.subscription.SubscriptionImpl
SubscriptionImpl.AckSubscription, SubscriptionImpl.BrowserSubscription, SubscriptionImpl.NoAckSubscription
 
Nested classes/interfaces inherited from interface org.apache.qpid.server.subscription.Subscription
Subscription.State, Subscription.StateListener
 
Constructor Summary
SubscriptionImpl.NoAckSubscription(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 isBrowser()
           
 boolean isExplicitAcknowledge()
           
 void send(QueueEntry entry)
          This method can be called by each of the publisher threads.
 boolean wouldSuspend(QueueEntry msg)
           
 
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, isTransient, 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

SubscriptionImpl.NoAckSubscription

public SubscriptionImpl.NoAckSubscription(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

isBrowser

public boolean isBrowser()
Specified by:
isBrowser in class SubscriptionImpl

isExplicitAcknowledge

public boolean isExplicitAcknowledge()
Specified by:
isExplicitAcknowledge in interface SubscriptionConfig
Overrides:
isExplicitAcknowledge in class SubscriptionImpl

send

public void send(QueueEntry entry)
          throws org.apache.qpid.AMQException
This method can be called by each of the publisher threads. As a result all changes to the channel object must be thread safe.

Specified by:
send in interface Subscription
Specified by:
send in class SubscriptionImpl
Parameters:
entry - The message to send
Throws:
org.apache.qpid.AMQException

wouldSuspend

public boolean wouldSuspend(QueueEntry msg)
Specified by:
wouldSuspend in interface Subscription
Overrides:
wouldSuspend in class SubscriptionImpl


Licensed to the Apache Software Foundation