@Test public void testTopicConsume() throws Exception { Assume.assumeTrue(JmsConfig.jmsTestsEnabled()); String rfc6167 = "jms:topic:" + getName(); JmsConsumer consumer = new JmsConsumer().withEndpoint(rfc6167);; consumer.setAcknowledgeMode("AUTO_ACKNOWLEDGE"); StandaloneConsumer standaloneConsumer = new StandaloneConsumer(activeMqBroker.getJmsConnection(), consumer); MockMessageListener jms = new MockMessageListener(); standaloneConsumer.registerAdaptrisMessageListener(jms); StandaloneProducer standaloneProducer = new StandaloneProducer(activeMqBroker.getJmsConnection(), new JmsProducer().withEndpoint(rfc6167)); execute(standaloneConsumer, standaloneProducer, createMessage(null), jms); assertMessages(jms, 1); }
public JmsConsumer withEndpoint(String s) { setEndpoint(s); return this; }
JmsConsumer extends JmsConsumerImpl { public JmsConsumer withEndpoint(String s) { setEndpoint(s); return this; } }
JmsConsumer extends JmsConsumerImpl { public JmsConsumer withEndpoint(String s) { setEndpoint(s); return this; } JmsConsumer();   JmsConsumer(boolean transacted); }
JmsConsumer extends JmsConsumerImpl { public JmsConsumer withEndpoint(String s) { setEndpoint(s); return this; } JmsConsumer();   JmsConsumer(boolean transacted); JmsConsumer withEndpoint(String s); }
JmsConsumer extends JmsConsumerImpl { public JmsConsumer withEndpoint(String s) { setEndpoint(s); return this; } JmsConsumer();   JmsConsumer(boolean transacted); JmsConsumer withEndpoint(String s);  }