org.jboss.mq.server
Class ExclusiveQueue
java.lang.Object
org.jboss.mq.server.BasicQueue (src)
org.jboss.mq.server.ExclusiveQueue
- public class ExclusiveQueue
- extends BasicQueue (src)
This class implements a basic queue with an exclusive subscription.
Methods inherited from class org.jboss.mq.server.BasicQueue (src) |
acknowledge, addReceiver, addSubscriber, addToReceivers, browse, clearEvent, clearEvents, createMessageCounter, dropMessage, dropMessage, getDescription, getMessageCounter, getQueueDepth, getReceivers, getReceiversCount, getScheduledMessageCount, isInUse, nackMessages, queueMessageForSending, receive, removeAllMessages, removeReceiver, setupMessageAcknowledgement, stop, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
ExclusiveQueue
public ExclusiveQueue(JMSDestinationManager (src) server,
SpyDestination (src) destination,
Subscription (src) exclusive,
BasicQueueParameters (src) parameters)
throws JMSException (src)
getExclusiveSubscription
public Subscription (src) getExclusiveSubscription()
addMessage
public void addMessage(MessageReference (src) mesRef,
Tx (src) txId)
throws JMSException (src)
- Description copied from class:
BasicQueue (src)
- Add a message to the queue
- Overrides:
addMessage
in class BasicQueue (src)
- Parameters:
mesRef
- the message referencetxId
- the transaction
- Throws:
JMSException (src)
- for any error
restoreMessage
public void restoreMessage(MessageReference (src) mesRef)
- Description copied from class:
BasicQueue (src)
- Restores a message.
- Overrides:
restoreMessage
in class BasicQueue (src)
removeSubscriber
public void removeSubscriber(Subscription (src) sub)
- Description copied from class:
BasicQueue (src)
- Removes a subscription from the queue
- Overrides:
removeSubscriber
in class BasicQueue (src)
- Parameters:
sub
- the subscription to remove