org.jboss.mq.server
Class PersistentQueue

java.lang.Object
  extended byorg.jboss.mq.server.BasicQueue (src) 
      extended byorg.jboss.mq.server.PersistentQueue
Direct Known Subclasses:
SelectorPersistentQueue (src)

public class PersistentQueue
extends BasicQueue (src)

This class implements a persistent version of the basic queue.


Constructor Summary
PersistentQueue(JMSDestinationManager (src)  server, SpyDestination (src)  destination, BasicQueueParameters (src)  parameters)
           
 
Method Summary
 void addMessage(MessageReference (src)  mesRef, Tx (src)  txId)
          Add a message to the queue
 SpyDestination (src) getSpyDestination()
           
 
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, removeSubscriber, restoreMessage, setupMessageAcknowledgement, stop, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

PersistentQueue

public PersistentQueue(JMSDestinationManager (src)  server,
                       SpyDestination (src)  destination,
                       BasicQueueParameters (src)  parameters)
                throws JMSException (src) 
Method Detail

getSpyDestination

public SpyDestination (src)  getSpyDestination()

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