flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSink.java [149:154]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        try {
            session.close();
        } catch (JMSException e) {
            if (logFailuresOnly) {
                LOG.error("Failed to close ActiveMQ session", e);
            } else {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-activemq/src/main/java/org/apache/flink/streaming/connectors/activemq/AMQSource.java [166:171]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        try {
            session.close();
        } catch (JMSException e) {
            if (logFailuresOnly) {
                LOG.error("Failed to close ActiveMQ session", e);
            } else {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -