org.apache.qpid.server.subscription
Class SubscriptionImpl.AckSubscription
java.lang.Object
org.apache.qpid.server.subscription.SubscriptionImpl
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
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 |
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
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