public void removeQueues()

in src/main/java/org/apache/openejb/cts/JMSAdminImpl.java [48:66]

• 19 lines of code
• 4 McCabe index (conditional complexity)

    public void removeQueues(final String[] queues) throws TSJMSAdminException {
        ActiveMQConnection connection = null;
        try {
            final ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            connection = (ActiveMQConnection) factory.createConnection();
            connection.start();
            for (int i = 0; i < queues.length; i++) {
                log.println(HEAD + "Destroying Queue: " + queues[i]);
                connection.destroyDestination(new ActiveMQQueue(queues[i]));
            }
        } catch (final JMSException e) {
            e.printStackTrace();
        } finally {
            try {
                connection.close();
            } catch (final Throwable ignore) {
            }
        }
    }