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

   1 package argeo.slc.activemq.selector;
   2
   3
   4 public class OsgiTest extends AbstractActiveMqTest {
   5         public void testSend() throws Exception {
   6                 producer.send(createMessage());
   7         }
   8
   9         protected void setUp() throws Exception {
  10                 connectorStr = "tcp://localhost:61616";
  11                 createSession();
  12         }
  13
  14         protected void tearDown() throws Exception {
  15                 session.close();
  16         }
  17
  18         /*
  19          * public static void main(String[] args) { try { ConnectionFactory
  20          * connectionFactory = new ActiveMQConnectionFactory(
  21          * "tcp://localhost:61616"); Connection connection =
  22          * connectionFactory.createConnection(); connection.start(); Session session
  23          * = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
  24          *
  25          * Queue queue = session.createQueue("testQueue"); MessageProducer producer
  26          * = session.createProducer(queue);
  27          *
  28          * // TextMessage msg = session.createTextMessage(); //
  29          * msg.setStringProperty(propName, propValue); // msg.setText(txt);
  30          *
  31          * } catch (JMSException e) { e.printStackTrace(); }
  32          *
  33          * }
  34          */
  35
  36 }