|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.console.filter.AbstractQueryFilter
org.apache.activemq.console.filter.AmqMessagesQueryFilter
public class AmqMessagesQueryFilter
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(URI brokerUrl,
Destination destination)
Create a JMS message query filter |
Method Summary | |
---|---|
protected Connection |
createConnection(URI brokerUrl)
Create and start a JMS connection |
URI |
getBrokerUrl()
Get the broker url being used. |
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(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 |
---|
public AmqMessagesQueryFilter(URI brokerUrl, Destination destination)
brokerUrl
- - broker url to connect todestination
- - JMS destination to queryMethod Detail |
---|
public List query(List queries) throws Exception
queries
- - message selector queries
Exception
protected List queryMessages(ActiveMQQueue queue, String selector) throws Exception
queue
- - queue destinationselector
- - message selector
Exception
protected List queryMessages(ActiveMQTopic topic, String selector) throws Exception
topic
- - topic destinationselector
- - message selector
Exception
protected Connection createConnection(URI brokerUrl) throws JMSException
brokerUrl
- - broker url to connect to.
JMSException
public URI getBrokerUrl()
public void setBrokerUrl(URI brokerUrl)
brokerUrl
- - broker urlpublic Destination getDestination()
public void setDestination(Destination destination)
destination
- - JMS destination
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |