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(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(URI brokerUrl)
Deprecated.
Use createConnection() instead, and pass the url to the ConnectionFactory when it's created.
|
URI |
getBrokerUrl()
Get the broker url being used.
|
javax.jms.Destination |
getDestination()
Get the destination being used.
|
List |
query(List queries)
Queries the specified destination using the message selector format query
|
protected List |
queryMessages(ActiveMQQueue queue,
String selector)
Query the messages of a queue destination using a queue browser
|
protected List |
queryMessages(ActiveMQTopic topic,
String selector)
Query the messages of a topic destination using a message consumer
|
void |
setBrokerUrl(URI brokerUrl)
Set the broker url to use.
|
void |
setDestination(javax.jms.Destination destination)
Set the destination to use.
|
query
public AmqMessagesQueryFilter(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 List query(List queries) throws Exception
queries
- - message selector queriesException
protected List queryMessages(ActiveMQQueue queue, String selector) throws Exception
queue
- - queue destinationselector
- - message selectorException
protected List queryMessages(ActiveMQTopic topic, String selector) throws Exception
topic
- - topic destinationselector
- - message selectorException
@Deprecated protected javax.jms.Connection createConnection(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 URI getBrokerUrl()
public void setBrokerUrl(URI brokerUrl)
brokerUrl
- - broker urlpublic javax.jms.Destination getDestination()
public void setDestination(javax.jms.Destination destination)
destination
- - JMS destinationCopyright © 2005–2014. All rights reserved.