@Override
    public Destination createDestination(final Session session, String name, final boolean topic) throws JMSException {
        Destination destination;

        if (topic) {
            name = URISupport.stripPrefix(name, "topic://");
            name = URISupport.stripPrefix(name, "topic:");
            destination = session.createTopic(name);
        } else {
            name = URISupport.stripPrefix(name, "queue://");
            name = URISupport.stripPrefix(name, "queue:");
            destination = session.createQueue(name);
        }

        return destination;
    }
@Test
    public void testQueueCreation() throws Exception {
        Queue destination = (Queue) strategy.createDestination(getSession(), "queue://test", false);
        assertNotNull(destination);
        assertEquals("test", destination.getQueueName());

        destination = (Queue) strategy.createDestination(getSession(), "queue:test", false);
        assertNotNull(destination);
        assertEquals("test", destination.getQueueName());

        destination = (Queue) strategy.createDestination(getSession(), "test", false);
        assertNotNull(destination);
        assertEquals("test", destination.getQueueName());
    }