|
||||||||||
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(java.net.URI brokerUrl,
javax.jms.Destination destination)
Create a JMS message query filter |
Method Summary | |
---|---|
protected javax.jms.Connection |
createConnection(java.net.URI brokerUrl)
Create and start a JMS connection |
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 |
---|
public AmqMessagesQueryFilter(java.net.URI brokerUrl, javax.jms.Destination destination)
brokerUrl
- - broker url to connect todestination
- - JMS destination to queryMethod Detail |
---|
public java.util.List query(java.util.List queries) throws java.lang.Exception
queries
- - message selector queries
java.lang.Exception
protected java.util.List queryMessages(ActiveMQQueue queue, java.lang.String selector) throws java.lang.Exception
queue
- - queue destinationselector
- - message selector
java.lang.Exception
protected java.util.List queryMessages(ActiveMQTopic topic, java.lang.String selector) throws java.lang.Exception
topic
- - topic destinationselector
- - message selector
java.lang.Exception
protected javax.jms.Connection createConnection(java.net.URI brokerUrl) throws javax.jms.JMSException
brokerUrl
- - broker url to connect to.
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 destination
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |