Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq.server
Class SelectorPersistentQueue

java.lang.Object
  extended byorg.jboss.mq.server.BasicQueue (src) 
      extended byorg.jboss.mq.server.PersistentQueue (src) 
          extended byorg.jboss.mq.server.SelectorPersistentQueue
public class SelectorPersistentQueue
extends PersistentQueue (src)

This class adds a selector to a persistent queue. Factored out of JMSTopic.

Constructor Summary
SelectorPersistentQueue(JMSDestinationManager (src)  server, SpyTopic (src)  dstopic, java.lang.String selector, BasicQueueParameters (src)  parameters)
          Create a new persistent queue with a selector
 
Method Summary
 void addMessage(MessageReference (src)  mesRef, Tx (src)  txId)
          Filters the message with the selector before adding to the queue
 
Methods inherited from class org.jboss.mq.server.PersistentQueue (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

SelectorPersistentQueue

public SelectorPersistentQueue(JMSDestinationManager (src)  server,
                               SpyTopic (src)  dstopic,
                               java.lang.String selector,
                               BasicQueueParameters (src)  parameters)
                        throws JMSException (src)
Create a new persistent queue with a selector

Parameters:
server - the destination manager
dstopic - the topic with a durable subscription
selector - the selector string
Throws:
JMSException (src) - for an error
Method Detail

addMessage

public void addMessage(MessageReference (src)  mesRef,
                       Tx (src)  txId)
                throws JMSException (src)
Filters the message with the selector before adding to the queue

Overrides:
addMessage in class PersistentQueue (src)
Parameters:
mesRef - the message
txId - the transaction
Throws:
JMSException (src) - for an error
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD