org.apache.qpid.server.subscription
Interface Subscription

All Known Implementing Classes:
BasicGetMethodHandler.GetNoAckSubscription, Subscription_0_10, SubscriptionImpl, SubscriptionImpl.AckSubscription, SubscriptionImpl.BrowserSubscription, SubscriptionImpl.NoAckSubscription

public interface Subscription


Nested Class Summary
static class Subscription.State
           
static interface Subscription.StateListener
           
 
Method Summary
 boolean acquires()
           
 void close()
           
 void confirmAutoClose()
           
 Object get(String key)
           
 QueueEntry.SubscriptionAssignedState getAssignedState()
           
 org.apache.qpid.framing.AMQShortString getConsumerTag()
           
 LogActor getLogActor()
           
 QueueEntry.SubscriptionAcquiredState getOwningState()
           
 AMQQueue getQueue()
           
 AMQQueue.Context getQueueContext()
           
 void getSendLock()
           
 Subscription.State getState()
           
 long getSubscriptionID()
           
 boolean hasInterest(QueueEntry msg)
           
 boolean isActive()
           
 boolean isAutoClose()
           
 boolean isClosed()
           
 boolean isSessionTransactional()
           
 boolean isSuspended()
           
 boolean isTransient()
           
 void onDequeue(QueueEntry queueEntry)
           
 void queueDeleted(AMQQueue queue)
           
 void releaseSendLock()
           
 void restoreCredit(QueueEntry queueEntry)
           
 boolean seesRequeues()
           
 void send(QueueEntry msg)
           
 void set(String key, Object value)
           
 void setNoLocal(boolean noLocal)
           
 void setQueue(AMQQueue queue, boolean exclusive)
           
 void setQueueContext(AMQQueue.Context queueContext)
           
 void setStateListener(Subscription.StateListener listener)
           
 boolean wouldSuspend(QueueEntry msg)
           
 

Method Detail

getLogActor

LogActor getLogActor()

isTransient

boolean isTransient()

getQueue

AMQQueue getQueue()

getOwningState

QueueEntry.SubscriptionAcquiredState getOwningState()

getAssignedState

QueueEntry.SubscriptionAssignedState getAssignedState()

setQueue

void setQueue(AMQQueue queue,
              boolean exclusive)

setNoLocal

void setNoLocal(boolean noLocal)

getConsumerTag

org.apache.qpid.framing.AMQShortString getConsumerTag()

getSubscriptionID

long getSubscriptionID()

isSuspended

boolean isSuspended()

hasInterest

boolean hasInterest(QueueEntry msg)

isAutoClose

boolean isAutoClose()

isClosed

boolean isClosed()

acquires

boolean acquires()

seesRequeues

boolean seesRequeues()

close

void close()

send

void send(QueueEntry msg)
          throws org.apache.qpid.AMQException
Throws:
org.apache.qpid.AMQException

queueDeleted

void queueDeleted(AMQQueue queue)

wouldSuspend

boolean wouldSuspend(QueueEntry msg)

getSendLock

void getSendLock()

releaseSendLock

void releaseSendLock()

onDequeue

void onDequeue(QueueEntry queueEntry)

restoreCredit

void restoreCredit(QueueEntry queueEntry)

setStateListener

void setStateListener(Subscription.StateListener listener)

getState

Subscription.State getState()

getQueueContext

AMQQueue.Context getQueueContext()

setQueueContext

void setQueueContext(AMQQueue.Context queueContext)

isActive

boolean isActive()

confirmAutoClose

void confirmAutoClose()

set

void set(String key,
         Object value)

get

Object get(String key)

isSessionTransactional

boolean isSessionTransactional()


Licensed to the Apache Software Foundation