spring-boot: JmsHealthIndicator doesn't work properly for ActiveMQ failover transport

For failover transport:

spring.activemq.broker-url: failover:(tcp://localhost:61616,tcp://127.0.0.1:61616)?randomize=false&nested.daemon=true

when ActiveMQ become unavailable JmsHealthIndicator reports UP. Our solution for this issue is to use TransportListener . See http://activemq.apache.org/how-can-i-monitor-the-connection-with-the-broker.html

public class TransportInteruptionListener extends DefaultTransportListener {
    private boolean interupted;

    @Override
    public void transportInterupted() {
         interupted = true;
    }
    @Override
    public void transportResumed() {
         interupted = false;
    }
    
    public boolean isInterupted() {
        return interupted;
    }
}

public class CustomJmsHealthIndicatorAutoConfiguration {

    @Bean
    public TransportInteruptionListener daivbTransportInteruptionListener() {
        return new TransportInteruptionListener();
    }
    
    @Bean
    @ConditionalOnMissingBean(name = "customJmsHealthIndicator")
    customJmsHealthIndicator customJmsHealthIndicator(ApplicationContext ctx, ConnectionFactory connectionFactory,
            TransportInteruptionListener l) {
        return new CustomJmsHealthIndicator(ctx, connectionFactory, l);
    }
    
    
    @Bean
    public ActiveMQConnectionFactoryCustomizer customActiveMQConnectionFactoryCustomizer(TransportInteruptionListener l) {
        return factory -> factory.setTransportListener(l);
    }
}

public class CustomJmsHealthIndicator extends AbstractHealthIndicator {
    ...
    protected void doHealthCheck(Health.Builder builder) throws Exception {
         ...
         connection.start();
          if (transportInteruptionListener.isInterupted()) {
             throw new IllegalStateException("Transport interupted");
         }
         ...
}