@Test public void testRfc6167_WithParams() throws Exception { EmbeddedActiveMq broker = new EmbeddedActiveMq(); StandaloneProducer producer = null; try { broker.start(); BasicActiveMqImplementation vendorImp = create(); PtpProducer ptp = new PtpProducer().withQueue((testName.getMethodName())); producer = new StandaloneProducer(broker.getJmsConnection(vendorImp), ptp); start(producer); producer.doService(AdaptrisMessageFactory.getDefaultInstance().newMessage("abcde")); JmsDestination jmsDest = vendorImp .createDestination( "jms:queue:MyQueueName?replyToName=StaticReplyTo&priority=1&deliveryMode=NON_PERSISTENT&timeToLive=1000", ptp); assertNotNull(jmsDest.getDestination()); assertTrue(javax.jms.Queue.class.isAssignableFrom(jmsDest.getDestination().getClass())); assertNotNull(jmsDest.getReplyToDestination()); assertTrue(javax.jms.Queue.class.isAssignableFrom(jmsDest.getReplyToDestination().getClass())); assertNotNull(jmsDest.deliveryMode()); assertEquals("NON_PERSISTENT", jmsDest.deliveryMode()); assertNotNull(jmsDest.priority()); assertEquals(Integer.valueOf(1), jmsDest.priority()); assertNotNull(jmsDest.timeToLive()); assertEquals(Long.valueOf(1000), jmsDest.timeToLive()); assertNull(jmsDest.subscriptionId()); assertFalse(jmsDest.noLocal()); } finally { stop(producer); broker.destroy(); } }
protected ActiveMQConnectionFactory create(String url) { return new ActiveMQConnectionFactory(url); }
BasicActiveMqImplementation extends UrlVendorImplementation implements VendorImplementation { protected ActiveMQConnectionFactory create(String url) { return new ActiveMQConnectionFactory(url); } }
BasicActiveMqImplementation extends UrlVendorImplementation implements VendorImplementation { protected ActiveMQConnectionFactory create(String url) { return new ActiveMQConnectionFactory(url); } BasicActiveMqImplementation();  BasicActiveMqImplementation(String url); }
BasicActiveMqImplementation extends UrlVendorImplementation implements VendorImplementation { protected ActiveMQConnectionFactory create(String url) { return new ActiveMQConnectionFactory(url); } BasicActiveMqImplementation();  BasicActiveMqImplementation(String url); @Override ConnectionFactory createConnectionFactory(); }
BasicActiveMqImplementation extends UrlVendorImplementation implements VendorImplementation { protected ActiveMQConnectionFactory create(String url) { return new ActiveMQConnectionFactory(url); } BasicActiveMqImplementation();  BasicActiveMqImplementation(String url); @Override ConnectionFactory createConnectionFactory();  }