org.jboss.mq.server
Class ExclusiveQueue

java.lang.Object
  extended byorg.jboss.mq.server.BasicQueue (src) 
      extended byorg.jboss.mq.server.ExclusiveQueue

public class ExclusiveQueue
extends BasicQueue (src)

This class implements a basic queue with an exclusive subscription.


Constructor Summary
ExclusiveQueue(JMSDestinationManager (src)  server, SpyDestination (src)  destination, Subscription (src)  exclusive, BasicQueueParameters (src)  parameters)
           
 
Method Summary
 void addMessage(MessageReference (src)  mesRef, Tx (src)  txId)
          Add a message to the queue
 Subscription (src) getExclusiveSubscription()
           
 void removeSubscriber(Subscription (src)  sub)
          Removes a subscription from the queue
 void restoreMessage(MessageReference (src)  mesRef)
          Restores a message.
 
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
 

Constructor Detail

ExclusiveQueue

public ExclusiveQueue(JMSDestinationManager (src)  server,
                      SpyDestination (src)  destination,
                      Subscription (src)  exclusive,
                      BasicQueueParameters (src)  parameters)
               throws JMSException (src) 
Method Detail

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