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

java.lang.Object
  extended by org.apache.qpid.server.subscription.SubscriptionImpl
      extended by org.apache.qpid.server.subscription.SubscriptionImpl.AckSubscription
All Implemented Interfaces:
ConfiguredObject<SubscriptionConfigType,SubscriptionConfig>, SubscriptionConfig, FlowCreditManager.FlowCreditManagerListener, Subscription
Enclosing class:
SubscriptionImpl

static final class SubscriptionImpl.AckSubscription
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.AckSubscription(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()
           
 void send(QueueEntry entry)
          This method can be called by each of the publisher threads.
 
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, isExplicitAcknowledge, isSessionTransactional, isSuspended, isTransient, onDequeue, queueDeleted, recordMessageDelivery, releaseSendLock, restoreCredit, seesRequeues, sendToClient, set, setNoLocal, setQueue, setQueueContext, setStateListener, toString, wouldSuspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

SubscriptionImpl.AckSubscription

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

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


Licensed to the Apache Software Foundation