public void removeTopics()

in src/main/java/org/apache/openejb/cts/JMSAdminImpl.java [79:97]

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

    public void removeTopics(final String[] topics) 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 < topics.length; i++) {
                log.println(HEAD + "Destroying Topic: " + topics[i]);
                connection.destroyDestination(new ActiveMQTopic(topics[i]));
            }
        } catch (final JMSException e) {
            e.printStackTrace();
        } finally {
            try {
                connection.close();
            } catch (final Throwable ignore) {
            }
        }
    }