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
|
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(org.apache.activemq.command.ActiveMQQueue queue,
String selector)
Query the messages of a queue destination using a queue browser
|
protected List |
queryMessages(org.apache.activemq.command.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)
connectionFactory
- - to connect withdestination
- - JMS destination to querypublic List query(List queries) throws Exception
queries
- - message selector queriesException
protected List queryMessages(org.apache.activemq.command.ActiveMQQueue queue, String selector) throws Exception
queue
- - queue destinationselector
- - message selectorException
protected List queryMessages(org.apache.activemq.command.ActiveMQTopic topic, String selector) throws Exception
topic
- - topic destinationselector
- - message selectorException
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–2018 FuseSource, Corp.. All rights reserved.