org.apache.activemq.broker.region.policy
public interface MessageQuery
Modifier and Type | Method and Description |
---|---|
void |
execute(ActiveMQDestination destination,
javax.jms.MessageListener listener)
Executes the query for messages; each message is passed into the listener
|
boolean |
validateUpdate(Message message)
Returns true if the given update is valid and does not overlap with the initial message query.
|
void execute(ActiveMQDestination destination, javax.jms.MessageListener listener) throws java.lang.Exception
destination
- the destination on which the query is to be performedlistener
- is the listener to notify as each message is created or loadedjava.lang.Exception
boolean validateUpdate(Message message)
message
- the update message which may have been sent before the query actually completedCopyright © 2005-2014. All Rights Reserved.