1 18 package org.apache.activemq.test.retroactive; 19 20 import javax.jms.MessageListener ; 21 22 import org.apache.activemq.broker.region.policy.MessageQuery; 23 import org.apache.activemq.command.ActiveMQDestination; 24 import org.apache.activemq.command.ActiveMQTextMessage; 25 import org.apache.activemq.command.Message; 26 import org.apache.commons.logging.Log; 27 import org.apache.commons.logging.LogFactory; 28 29 33 public class DummyMessageQuery implements MessageQuery { 34 35 protected static final Log log = LogFactory.getLog(DummyMessageQuery.class); 36 37 public static int messageCount = 10; 38 39 public void execute(ActiveMQDestination destination, MessageListener listener) throws Exception { 40 log.info("Initial query is creating: " + messageCount + " messages"); 41 for (int i = 0; i < messageCount; i++) { 42 ActiveMQTextMessage message = new ActiveMQTextMessage(); 43 message.setText("Initial message: " + i + " loaded from query"); 44 listener.onMessage(message); 45 } 46 } 47 48 public boolean validateUpdate(Message message) { 49 return true; 50 } 51 } 52 | Popular Tags |