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