org.apache.activemq.console.filter
public class AmqMessagesQueryFilter extends AbstractQueryFilter
next
QUERY_DELIMETER
Constructor and Description |
---|
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
|
Modifier and Type | Method and Description |
---|---|
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.
|
query
public AmqMessagesQueryFilter(java.net.URI brokerUrl, javax.jms.Destination destination)
brokerUrl
- - broker url to connect todestination
- - JMS destination to querypublic AmqMessagesQueryFilter(javax.jms.ConnectionFactory connectionFactory, javax.jms.Destination destination)
brokerUrl
- - broker url to connect todestination
- - JMS destination to querypublic java.util.List query(java.util.List queries) throws java.lang.Exception
queries
- - message selector queriesjava.lang.Exception
protected java.util.List queryMessages(ActiveMQQueue queue, java.lang.String selector) throws java.lang.Exception
queue
- - queue destinationselector
- - message selectorjava.lang.Exception
protected java.util.List queryMessages(ActiveMQTopic topic, java.lang.String selector) throws java.lang.Exception
topic
- - topic destinationselector
- - message selectorjava.lang.Exception
@Deprecated protected javax.jms.Connection createConnection(java.net.URI brokerUrl) throws javax.jms.JMSException
brokerUrl
- - broker url to connect to.javax.jms.JMSException
protected javax.jms.Connection createConnection() throws javax.jms.JMSException
javax.jms.JMSException
public java.net.URI getBrokerUrl()
public void setBrokerUrl(java.net.URI brokerUrl)
brokerUrl
- - broker urlpublic javax.jms.Destination getDestination()
public void setDestination(javax.jms.Destination destination)
destination
- - JMS destinationCopyright © 2005-2014. All Rights Reserved.