sandbox/argeo.slc.activemq.selector/src/test/java/argeo/slc/activemq/selector/SelectorTest.java

   1 package argeo.slc.activemq.selector;
   2
   3 import javax.jms.Connection;
   4 import javax.jms.ConnectionFactory;
   5 import javax.jms.MessageConsumer;
   6 import javax.jms.MessageProducer;
   7 import javax.jms.Queue;
   8 import javax.jms.Session;
   9 import javax.jms.TextMessage;
  10
  11 import junit.framework.TestCase;
  12
  13 import org.apache.activemq.ActiveMQConnectionFactory;
  14 import org.apache.activemq.broker.BrokerService;
  15
  16 public class SelectorTest extends AbstractActiveMqTest {
  17         // private final static Log log = LogFactory.getLog(SelectorTest.class);
  18
  19         protected BrokerService broker;
  20         protected String connectorStr = "vm://localhost";
  21
  22         protected String propName = "myFilter";
  23         protected String propValue = "myValue";
  24         protected String txt = "myText";
  25
  26         protected Session session;
  27         protected Queue queue;
  28         protected MessageProducer producer;
  29
  30         public void testNoFilter() throws Exception {
  31                 producer.send(createMessage());
  32                 TextMessage receivedMsg = (TextMessage) session.createConsumer(queue)
  33                                 .receive(2000);
  34                 assertMsg(receivedMsg);
  35         }
  36
  37         public void testFilterOk() throws Exception {
  38                 producer.send(createMessage());
  39                 MessageConsumer consumer = session.createConsumer(queue, propName
  40                                 + "='" + propValue + "'");
  41                 TextMessage receivedMsg = (TextMessage) consumer.receive(2000);
  42                 assertMsg(receivedMsg);
  43         }
  44
  45         public void testFilterNok() throws Exception {
  46                 producer.send(createMessage());
  47                 MessageConsumer consumer = session.createConsumer(queue, propName
  48                                 + "='notMyValue'");
  49                 TextMessage receivedMsg = (TextMessage) consumer.receive(1000);
  50                 assertNull("Message reception should time out", receivedMsg);
  51         }
  52
  53         protected void setUp() throws Exception {
  54                 broker = new BrokerService();
  55                 broker.setPersistent(false);
  56                 broker.setUseJmx(false);
  57                 broker.addConnector(connectorStr);
  58                 broker.start();
  59
  60                 createSession();
  61         }
  62
  63         protected void tearDown() throws Exception {
  64                 if (broker != null) {
  65                         broker.stop();
  66                 }
  67         }
  68
  69 }