Uses of Interface
org.apache.qpid.server.subscription.Subscription

Packages that use Subscription
org.apache.qpid.server   
org.apache.qpid.server.handler   
org.apache.qpid.server.logging.actors   
org.apache.qpid.server.logging.subjects   
org.apache.qpid.server.queue   
org.apache.qpid.server.subscription   
 

Uses of Subscription in org.apache.qpid.server
 

Fields in org.apache.qpid.server with type parameters of type Subscription
protected  Map<org.apache.qpid.framing.AMQShortString,Subscription> AMQChannel._tag2SubscriptionMap
          Maps from consumer tag to subscription instance.
 

Methods in org.apache.qpid.server that return Subscription
 Subscription AMQChannel.getSubscription(org.apache.qpid.framing.AMQShortString subscription)
           
 

Methods in org.apache.qpid.server with parameters of type Subscription
 void AMQChannel.addUnacknowledgedMessage(QueueEntry entry, long deliveryTag, Subscription subscription)
          Add a message to the channel-based list of unacknowledged messages
 

Uses of Subscription in org.apache.qpid.server.handler
 

Classes in org.apache.qpid.server.handler that implement Subscription
static class BasicGetMethodHandler.GetNoAckSubscription
           
 

Uses of Subscription in org.apache.qpid.server.logging.actors
 

Constructors in org.apache.qpid.server.logging.actors with parameters of type Subscription
SubscriptionActor(RootMessageLogger logger, Subscription subscription)
           
 

Uses of Subscription in org.apache.qpid.server.logging.subjects
 

Constructors in org.apache.qpid.server.logging.subjects with parameters of type Subscription
SubscriptionLogSubject(Subscription subscription)
          Create an QueueLogSubject that Logs in the following format.
 

Uses of Subscription in org.apache.qpid.server.queue
 

Methods in org.apache.qpid.server.queue that return Subscription
 Subscription QueueEntry.getDeliveredSubscription()
           
 Subscription QueueEntryImpl.getDeliveredSubscription()
           
 Subscription QueueEntry.SubscriptionAcquiredState.getSubscription()
           
 Subscription QueueEntry.SubscriptionAssignedState.getSubscription()
           
 

Methods in org.apache.qpid.server.queue with parameters of type Subscription
 boolean QueueEntry.acquire(Subscription sub)
           
 boolean QueueEntryImpl.acquire(Subscription sub)
           
 void AMQQueue.deliverAsync(Subscription sub)
           
 void SimpleAMQQueue.deliverAsync(Subscription sub)
           
 void AMQQueue.dequeue(QueueEntry entry, Subscription sub)
           
 void SimpleAMQQueue.dequeue(QueueEntry entry, Subscription sub)
           
 void AMQQueue.flushSubscription(Subscription sub)
           
 void SimpleAMQQueue.flushSubscription(Subscription sub)
           
 boolean SimpleAMQQueue.flushSubscription(Subscription sub, long iterations)
           
 boolean QueueEntry.isAcquiredBy(Subscription subscription)
           
 boolean QueueEntryImpl.isAcquiredBy(Subscription subscription)
           
 boolean QueueEntry.isRejectedBy(Subscription subscription)
           
 boolean QueueEntryImpl.isRejectedBy(Subscription subscription)
           
 void AMQQueue.registerSubscription(Subscription subscription, boolean exclusive)
           
 void SimpleAMQQueue.registerSubscription(Subscription subscription, boolean exclusive)
           
 void QueueEntry.reject(Subscription subscription)
           
 void QueueEntryImpl.reject(Subscription subscription)
           
 void AMQQueue.requeue(QueueEntryImpl storeContext, Subscription subscription)
           
 void SimpleAMQQueue.requeue(QueueEntryImpl entry, Subscription subscription)
           
 void QueueEntry.requeue(Subscription subscription)
           
 void QueueEntryImpl.requeue(Subscription subscription)
           
 boolean AMQQueue.resend(QueueEntry entry, Subscription subscription)
           
 boolean SimpleAMQQueue.resend(QueueEntry entry, Subscription subscription)
           
 void SimpleAMQQueue.stateChange(Subscription sub, Subscription.State oldState, Subscription.State newState)
           
 void AMQQueue.unregisterSubscription(Subscription subscription)
           
 void SimpleAMQQueue.unregisterSubscription(Subscription subscription)
           
 

Constructors in org.apache.qpid.server.queue with parameters of type Subscription
QueueEntry.SubscriptionAcquiredState(Subscription subscription)
           
QueueEntry.SubscriptionAssignedState(Subscription subscription)
           
SubFlushRunner(Subscription sub)
           
 

Uses of Subscription in org.apache.qpid.server.subscription
 

Classes in org.apache.qpid.server.subscription that implement Subscription
 class Subscription_0_10
           
 class SubscriptionImpl
          Encapsulation of a supscription to a queue.
(package private) static class SubscriptionImpl.AckSubscription
           
(package private) static class SubscriptionImpl.BrowserSubscription
           
static class SubscriptionImpl.NoAckSubscription
           
 

Methods in org.apache.qpid.server.subscription that return Subscription
 Subscription SubscriptionFactory.createSubscription(AMQChannel channel, AMQProtocolSession protocolSession, org.apache.qpid.framing.AMQShortString consumerTag, boolean acks, org.apache.qpid.framing.FieldTable filters, boolean noLocal, FlowCreditManager creditManager, ClientDeliveryMethod clientMethod, RecordDeliveryMethod recordMethod)
           
 Subscription SubscriptionFactoryImpl.createSubscription(AMQChannel channel, AMQProtocolSession protocolSession, org.apache.qpid.framing.AMQShortString consumerTag, boolean acks, org.apache.qpid.framing.FieldTable filters, boolean noLocal, FlowCreditManager creditManager, ClientDeliveryMethod clientMethod, RecordDeliveryMethod recordMethod)
           
 Subscription SubscriptionFactory.createSubscription(int channel, AMQProtocolSession protocolSession, org.apache.qpid.framing.AMQShortString consumerTag, boolean acks, org.apache.qpid.framing.FieldTable filters, boolean noLocal, FlowCreditManager creditManager)
           
 Subscription SubscriptionFactoryImpl.createSubscription(int channelId, AMQProtocolSession protocolSession, org.apache.qpid.framing.AMQShortString consumerTag, boolean acks, org.apache.qpid.framing.FieldTable filters, boolean noLocal, FlowCreditManager creditManager)
           
 Subscription SubscriptionList.SubscriptionNode.getSubscription()
           
 

Methods in org.apache.qpid.server.subscription with parameters of type Subscription
 SubscriptionList.SubscriptionNode SubscriptionList.add(Subscription sub)
           
 void ClientDeliveryMethod.deliverToClient(Subscription sub, QueueEntry entry, long deliveryTag)
           
 void RecordDeliveryMethod.recordMessageDelivery(Subscription sub, QueueEntry entry, long deliveryTag)
           
 boolean SubscriptionList.remove(Subscription sub)
           
 void Subscription.StateListener.stateChange(Subscription sub, Subscription.State oldState, Subscription.State newState)
           
 

Constructors in org.apache.qpid.server.subscription with parameters of type Subscription
SubscriptionList.SubscriptionNode(Subscription sub)
           
 



Licensed to the Apache Software Foundation