public void close()

in flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java [147:173]

• 25 lines of code
• 7 McCabe index (conditional complexity)

    public void close() {
        RuntimeException t = null;
        try {
            session.close();
        } catch (JMSException e) {
            if (logFailuresOnly) {
                LOG.error("Failed to close ActiveMQ session", e);
            } else {
                t = new RuntimeException("Failed to close ActiveMQ session", e);
            }
        }

        try {
            connection.close();
        } catch (JMSException e) {
            if (logFailuresOnly) {
                LOG.error("Failed to close ActiveMQ connection", e);
            } else {
                t = t == null    ? new RuntimeException("Failed to close ActiveMQ session", e)
                                : t;
            }
        }

        if (t != null) {
            throw t;
        }
    }