| java.lang.Object org.jboss.mq.server.BasicQueue org.jboss.mq.server.PersistentQueue
All known Subclasses: org.jboss.mq.server.SelectorPersistentQueue,
PersistentQueue | public class PersistentQueue extends org.jboss.mq.server.BasicQueue (Code) | | This class implements a persistent version of the basic queue.
author: David Maplesden (David.Maplesden@orion.co.nz) |
Methods inherited from org.jboss.mq.server.BasicQueue | public void acknowledge(AcknowledgementRequest item, Tx txId) throws JMSException(Code)(Java Doc) public void addMessage(MessageReference mes, Tx txId) throws JMSException(Code)(Java Doc) public void addReceiver(Subscription sub) throws JMSException(Code)(Java Doc) public void addSubscriber(Subscription sub) throws JMSException(Code)(Java Doc) protected void addToReceivers(Subscription sub) throws JMSException(Code)(Java Doc) public SpyMessage[] browse(String selector) throws JMSException(Code)(Java Doc) public List browseInProcess(String selector) throws JMSException(Code)(Java Doc) public List browseScheduled(String selector) throws JMSException(Code)(Java Doc) protected void clearEvent(MessageReference message)(Code)(Java Doc) protected void clearEvents()(Code)(Java Doc) public void createMessageCounter(String name, String subscription, boolean topic, boolean durable, int daycountmax)(Code)(Java Doc) protected void dropMessage(MessageReference message)(Code)(Java Doc) protected void dropMessage(MessageReference message, Tx txid)(Code)(Java Doc) protected void expireMessage(MessageReference messageRef)(Code)(Java Doc) protected void expireMessageAsync(MessageReference messageRef)(Code)(Java Doc) public String getDescription()(Code)(Java Doc) public int getInProcessMessageCount()(Code)(Java Doc) public MessageCounter getMessageCounter()(Code)(Java Doc) public int getQueueDepth()(Code)(Java Doc) public ArrayList getReceivers()(Code)(Java Doc) public int getReceiversCount()(Code)(Java Doc) public int getScheduledMessageCount()(Code)(Java Doc) public Set getSubscribers()(Code)(Java Doc) public boolean isInUse()(Code)(Java Doc) protected void nackMessage(MessageReference message)(Code)(Java Doc) public void nackMessages(Subscription sub)(Code)(Java Doc) protected void performOrPrepareAcknowledgeMessage(MessageReference mes, Tx txId) throws JMSException(Code)(Java Doc) protected void performOrPrepareAddMessage(MessageReference mes, Tx txId) throws Exception(Code)(Java Doc) protected void queueMessageForSending(Subscription sub, MessageReference message)(Code)(Java Doc) public SpyMessage receive(Subscription sub, boolean wait) throws JMSException(Code)(Java Doc) public void removeAllMessages() throws JMSException(Code)(Java Doc) protected void removeReceiver(Subscription sub)(Code)(Java Doc) public void removeSubscriber(Subscription sub)(Code)(Java Doc) public void restoreMessage(MessageReference mes)(Code)(Java Doc) public void restoreMessage(MessageReference mes, Tx txid, int type)(Code)(Java Doc) protected void setupMessageAcknowledgement(Subscription sub, MessageReference messageRef) throws JMSException(Code)(Java Doc) public void stop()(Code)(Java Doc) public String toString()(Code)(Java Doc)
|
|
|