SelectorPersistentQueue (JBoss Messaging API) - JBoss 3.2.7 messaging API Documentation 英文版文档

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.jboss.mq.server
Class SelectorPersistentQueue

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

public class SelectorPersistentQueue
extends PersistentQueue

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

Author:: Adrian Brock (Adrian.Brock@HappeningTimes.com)

Constructor Summary

SelectorPersistentQueue(JMSDestinationManager server, SpyTopic dstopic, String selector, BasicQueueParameters parameters)
Create a new persistent queue with a selector

Method Summary

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

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

getSpyDestination

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

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 server,
                               SpyTopic dstopic,
                               String selector,
                               BasicQueueParameters parameters)
                        throws javax.jms.JMSException

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:: javax.jms.JMSException - for an error

Method Detail

addMessage

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

Filters the message with the selector before adding to the queue

Overrides:: addMessage in class PersistentQueue

Parameters:: mesRef - the message; txId - the transaction
Throws:: javax.jms.JMSException - for an error