org.jboss.mq.server
Class PersistentQueue

java.lang.Object
  org.jboss.mq.server.BasicQueue
      org.jboss.mq.server.PersistentQueue

Direct Known Subclasses:

SelectorPersistentQueue

public class PersistentQueue
extends BasicQueue

This class implements a persistent version of the basic queue.

Author:

David Maplesden (David.Maplesden@orion.co.nz)

Constructor Summary

PersistentQueue(JMSDestinationManager server, SpyDestination destination, BasicQueueParameters parameters)

Method Summary

void	addMessage(MessageReference mesRef, Tx txId) Add a message to the queue
SpyDestination	getSpyDestination()

Methods inherited from class org.jboss.mq.server.BasicQueue

acknowledge, addReceiver, addSubscriber, addToReceivers, browse, clearEvent, clearEvents, createMessageCounter, dropMessage, dropMessage, expireMessage, expireMessageAsync, getDescription, getMessageCounter, getQueueDepth, getReceivers, getReceiversCount, getScheduledMessageCount, getSubscribers, isInUse, nackMessage, 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 server,
                       SpyDestination destination,
                       BasicQueueParameters parameters)
                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

getSpyDestination

public SpyDestination getSpyDestination()

addMessage

public void addMessage(MessageReference mesRef,
                       Tx txId)
                throws javax.jms.JMSException

Description copied from class: BasicQueue

Add a message to the queue

Overrides:

addMessage in class BasicQueue

Parameters:

mesRef - the message reference

txId - the transaction

Throws:

javax.jms.JMSException - for any error