@Test public void testRfc6167_Invalid() 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")); try { JmsDestination jmsDest = vendorImp.createDestination("hello:queue:myQueueName", ptp); } catch (JMSException e) { assertTrue(e.getMessage().startsWith("failed to parse")); } try { JmsDestination jmsDest = vendorImp.createDestination(null, ptp); } catch (JMSException e) { assertTrue(e.getMessage().startsWith("failed to parse")); } } 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();  }