org.apache.qpid.server.subscription
Class SubscriptionImpl.NoAckSubscription
java.lang.Object
org.apache.qpid.server.subscription.SubscriptionImpl
org.apache.qpid.server.subscription.SubscriptionImpl.NoAckSubscription
- All Implemented Interfaces:
- ConfiguredObject<SubscriptionConfigType,SubscriptionConfig>, SubscriptionConfig, FlowCreditManager.FlowCreditManagerListener, Subscription
- Direct Known Subclasses:
- BasicGetMethodHandler.GetNoAckSubscription
- Enclosing class:
- SubscriptionImpl
public static class SubscriptionImpl.NoAckSubscription
- extends SubscriptionImpl
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, isSessionTransactional, isSuspended, isTransient, onDequeue, queueDeleted, recordMessageDelivery, releaseSendLock, restoreCredit, seesRequeues, sendToClient, set, setNoLocal, setQueue, setQueueContext, setStateListener, toString |
SubscriptionImpl.NoAckSubscription
public SubscriptionImpl.NoAckSubscription(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
isExplicitAcknowledge
public boolean isExplicitAcknowledge()
- Specified by:
isExplicitAcknowledge
in interface SubscriptionConfig
- Overrides:
isExplicitAcknowledge
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
wouldSuspend
public boolean wouldSuspend(QueueEntry msg)
- Specified by:
wouldSuspend
in interface Subscription
- Overrides:
wouldSuspend
in class SubscriptionImpl
Licensed to the Apache Software Foundation