Повторная доставка Spring Boot JMS ActiveMQ при аварийном переключении

У меня есть потребительское приложение, которое использует Spring Boot JMS для прослушивания сообщения из очереди. Это приложение подключено к кластеру ActiveMQ с аварийным переключением для обеспечения высокой доступности. Но у меня возникает следующая проблема: когда я выключаю один из брокеров, и приложение обрабатывает одно сообщение, это сообщение не удаляется из очереди, а когда приложение подключается к другому брокеру, сообщение доставляется повторно. Проблема в том, что сообщение было обработано в первый раз, и мне не нужно его обрабатывать повторно.

Я искал режимы подтверждения и пытался использовать клиентский режим для принудительного подтверждения перед обработкой сообщения. Но я не работал. Любая идея??

Я объявил следующие бобы:

@Bean
    public ActiveMQConnectionFactory jmsConnectionFactory() {
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
        connectionFactory.setUserName(brokerName);
        connectionFactory.setPassword(brokerPassword);
        connectionFactory.setTrustAllPackages(true);
        return connectionFactory;
    }

    @Bean
    public JmsTemplate jmsTemplate() {
        JmsTemplate jmsTemplate = new JmsTemplate();
        jmsTemplate.setConnectionFactory(jmsConnectionFactory());
        jmsTemplate.setSessionTransacted(false);
        jmsTemplate.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
        jmsTemplate.setDefaultDestinationName(REMOTE_T);
        return jmsTemplate;
    }


    @Bean
    public JmsListenerContainerFactory<?> jmsListenerContainerFactory(
            @Qualifier("jmsConnectionFactory") ConnectionFactory connectionFactory,
            DefaultJmsListenerContainerFactoryConfigurer configurer) {
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setSessionTransacted(false);
        factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
        configurer.configure(factory, connectionFactory);
        return factory;
    }

Код моего слушателя:

@JmsListener(destination = "Consumer.consumer1.VirtualTopic.TopicPrueba", containerFactory = "jmsListenerContainerFactory")
    public void receiveMessageFromContacts(Message message) {
        try {
            message.acknowledge();
            TextMessage txtMessage = (TextMessage)message;
            mensajesConsumer1++;
            System.out.println("First Consumer:"+ txtMessage.getText()+ " received:"+mensajesConsumer1);    
        }catch(JMSException e) {
            e.printStackTrace();
        }
    }

Не уверен, правильно ли я понял режим подтверждения клиента.

Пожалуйста помоги! :)

Заранее спасибо!