org.apache.qpid.server.subscription
Class SubscriptionImpl.BrowserSubscription
java.lang.Object
org.apache.qpid.server.subscription.SubscriptionImpl
org.apache.qpid.server.subscription.SubscriptionImpl.BrowserSubscription
- All Implemented Interfaces:
- ConfiguredObject<SubscriptionConfigType,SubscriptionConfig>, SubscriptionConfig, FlowCreditManager.FlowCreditManagerListener, Subscription
- Enclosing class:
- SubscriptionImpl
static final class SubscriptionImpl.BrowserSubscription
- 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, isExplicitAcknowledge, isSessionTransactional, isSuspended, isTransient, onDequeue, queueDeleted, recordMessageDelivery, releaseSendLock, restoreCredit, seesRequeues, sendToClient, set, setNoLocal, setQueue, setQueueContext, setStateListener, toString |
SubscriptionImpl.BrowserSubscription
public SubscriptionImpl.BrowserSubscription(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 msg)
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:
msg
- 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