@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 testTopicCreation() throws Exception {
        Topic destination = (Topic) strategy.createDestination(getSession(), "topic://test", true);
        assertNotNull(destination);
        assertEquals("test", destination.getTopicName());

        destination = (Topic) strategy.createDestination(getSession(), "topic:test", true);
        assertNotNull(destination);
        assertEquals("test", destination.getTopicName());

        destination = (Topic) strategy.createDestination(getSession(), "test", true);
        assertNotNull(destination);
        assertEquals("test", destination.getTopicName());
    }