Hello, I have a scenario where messages are failing to propagate over a network connector between two brokers.
My scenario has been simplified for the purpose of diagnosis. I have 2 brokers with 2 network connectors between them going one way, utilising two physical connections to achieve both performance AND resilience. Each broker has several consumers connected but there is only 1 producer. All messages occur on the same topic with selectors: ┌────────┐ ┌────────┐ │Consumer│ │Consumer│ └───────┬┘ └──┬─────┘ │ │ │ │ ┌─┴──────┐ NC1 ┌───────┴┐ ┌────────┐ │ ├──────────────────►│ │ ┌────────┐ │Producer├───────┤Broker1 │ │Broker2 ├──────┤Consumer│ └────────┘ │ ├──────────────────►│ │ └────────┘ └─┬──────┘ NC2 └───────┬┘ │ │ │ │ │ │ ┌───────┴┐ ┌──┴─────┐ │Consumer│ │Consumer│ └────────┘ └────────┘ The error occurs when one of the network connectors fail. When this happens, consumers connected to Broker2 stop receiving messages, sometimes all messages, sometimes just a subset. Note: If I restart a consumer connected to Broker2 that is set to receive all messages, then everything starts working again. I ran this scenario on both 5.17.5 and 5.18.2. Below is my activemq.xml for Broker1: <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"> <broker xmlns="http://activemq.apache.org/schema/core" start="false" brokerName="localhost" dataDirectory="${activemq.data}" schedulerSupport="false" persistent="true" > <transportConnectors> <transportConnector name="nio" uri="nio://0.0.0.0:61616"/> </transportConnectors> <networkConnectors> <networkConnector name="UK-WindowsPMC1-USCentral-WindowsBroker1-BR0-000" consumerPriorityBase="-5" decreaseNetworkConsumerPriority="true" networkTTL="1" conduitSubscriptions="false" uri="static:(tcp://10.10.10.3:61616)"></networkConnector> <networkConnector name="UK-WindowsPMC1-USCentral-WindowsBroker1-BR1-000" consumerPriorityBase="-5" decreaseNetworkConsumerPriority="true" networkTTL="1" conduitSubscriptions="false" uri="static:(tcp://10.0.0.3:61616)"></networkConnector> </networkConnectors> </broker> </beans> The configuration for Broker2 is identical, but without the network connectors. I believe that this setup should work and that if one of the network connectors fail the other one should take over. Is this not the case? Is there something that I'm missing? Many thanks Paul