org.apache.activemq.console.filter
Class AmqMessagesQueryFilter

java.lang.Object
  extended by org.apache.activemq.console.filter.AbstractQueryFilter
      extended by org.apache.activemq.console.filter.AmqMessagesQueryFilter
All Implemented Interfaces:
QueryFilter

public class AmqMessagesQueryFilter
extends AbstractQueryFilter


Field Summary
 
Fields inherited from class org.apache.activemq.console.filter.AbstractQueryFilter
next
 
Fields inherited from interface org.apache.activemq.console.filter.QueryFilter
QUERY_DELIMETER
 
Constructor Summary
AmqMessagesQueryFilter(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination destination)
          Create a JMS message query filter
AmqMessagesQueryFilter(java.net.URI brokerUrl, javax.jms.Destination destination)
          Create a JMS message query filter
 
Method Summary
protected  javax.jms.Connection createConnection()
          Create and start a JMS connection
protected  javax.jms.Connection createConnection(java.net.URI brokerUrl)
          Deprecated. Use createConnection() instead, and pass the url to the ConnectionFactory when it's created.
 java.net.URI getBrokerUrl()
          Get the broker url being used.
 javax.jms.Destination getDestination()
          Get the destination being used.
 java.util.List query(java.util.List queries)
          Queries the specified destination using the message selector format query
protected  java.util.List queryMessages(ActiveMQQueue queue, java.lang.String selector)
          Query the messages of a queue destination using a queue browser
protected  java.util.List queryMessages(ActiveMQTopic topic, java.lang.String selector)
          Query the messages of a topic destination using a message consumer
 void setBrokerUrl(java.net.URI brokerUrl)
          Set the broker url to use.
 void setDestination(javax.jms.Destination destination)
          Set the destination to use.
 
Methods inherited from class org.apache.activemq.console.filter.AbstractQueryFilter
query
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AmqMessagesQueryFilter

public AmqMessagesQueryFilter(java.net.URI brokerUrl,
                              javax.jms.Destination destination)
Create a JMS message query filter

Parameters:
brokerUrl - - broker url to connect to
destination - - JMS destination to query

AmqMessagesQueryFilter

public AmqMessagesQueryFilter(javax.jms.ConnectionFactory connectionFactory,
                              javax.jms.Destination destination)
Create a JMS message query filter

Parameters:
brokerUrl - - broker url to connect to
destination - - JMS destination to query
Method Detail

query

public java.util.List query(java.util.List queries)
                     throws java.lang.Exception
Queries the specified destination using the message selector format query

Parameters:
queries - - message selector queries
Returns:
list messages that matches the selector
Throws:
java.lang.Exception

queryMessages

protected java.util.List queryMessages(ActiveMQQueue queue,
                                       java.lang.String selector)
                                throws java.lang.Exception
Query the messages of a queue destination using a queue browser

Parameters:
queue - - queue destination
selector - - message selector
Returns:
list of messages that matches the selector
Throws:
java.lang.Exception

queryMessages

protected java.util.List queryMessages(ActiveMQTopic topic,
                                       java.lang.String selector)
                                throws java.lang.Exception
Query the messages of a topic destination using a message consumer

Parameters:
topic - - topic destination
selector - - message selector
Returns:
list of messages that matches the selector
Throws:
java.lang.Exception

createConnection

@Deprecated
protected javax.jms.Connection createConnection(java.net.URI brokerUrl)
                                         throws javax.jms.JMSException
Deprecated. Use createConnection() instead, and pass the url to the ConnectionFactory when it's created.

Create and start a JMS connection

Parameters:
brokerUrl - - broker url to connect to.
Returns:
JMS connection
Throws:
javax.jms.JMSException

createConnection

protected javax.jms.Connection createConnection()
                                         throws javax.jms.JMSException
Create and start a JMS connection

Returns:
JMS connection
Throws:
javax.jms.JMSException

getBrokerUrl

public java.net.URI getBrokerUrl()
Get the broker url being used.

Returns:
broker url

setBrokerUrl

public void setBrokerUrl(java.net.URI brokerUrl)
Set the broker url to use.

Parameters:
brokerUrl - - broker url

getDestination

public javax.jms.Destination getDestination()
Get the destination being used.

Returns:
- JMS destination

setDestination

public void setDestination(javax.jms.Destination destination)
Set the destination to use.

Parameters:
destination - - JMS destination


Copyright © 2005-2015. All Rights Reserved.