sandbox/argeo.slc.activemq.selector/src/test/java/argeo/slc/activemq/selector/AbstractActiveMqTest.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 abstract class AbstractActiveMqTest extends TestCase {
  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         protected void createSession() throws Exception {
  31                 ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
  32                                 connectorStr);
  33                 Connection connection = connectionFactory.createConnection();
  34                 connection.start();
  35                 session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  36
  37                 queue = session.createQueue("testQueue");
  38                 producer = session.createProducer(queue);
  39         }
  40
  41         protected TextMessage createMessage() throws Exception {
  42                 TextMessage msg = session.createTextMessage();
  43                 msg.setStringProperty(propName, propValue);
  44                 msg.setText(txt);
  45                 return msg;
  46         }
  47
  48         protected void assertMsg(TextMessage receivedMsg) throws Exception {
  49                 assertNotNull(receivedMsg);
  50                 assertEquals(propValue, receivedMsg.getStringProperty(propName));
  51                 assertEquals(txt, receivedMsg.getText());
  52         }
  53
  54 }