I see you're using a clustered configuration with JGroups. I assume that your nodes are all clustering together and connecting their bridges as expected. If they aren't then that would certainly cause a problem. However, even if they are clustering properly you're using this in your cluster-connection:
<max-hops>0</max-hops> This will prevent the movement of messages between cluster nodes. I recommend you change this to: <max-hops>1</max-hops> Let me know if that helps. Justin On Fri, Nov 21, 2025 at 11:59 AM Gunawan, Rahman (GSFC-SEWP)[Halvik Corp] via users <[email protected]> wrote: > We are using microservices and these microservices communicate via > broker. So, the producer put messages in queue1 and consumer listens to > queue 1 and pick up the messages. > Attached is the broker.xml. Each pair has different group name e.g. pair > 1 has group name groupA, pair 2 has group name groupB, etc. > > > Rahman Gunawan > SITSS Software Developer > NASA SEWP / SITSS > HALVIK Corporation > 7601 Ora Glen Dr, Greenbelt, MD 20770 > C: 240.444.6003 > O: 301.614.5257 > [email protected] > > > -----Original Message----- > From: Justin Bertram <[email protected]> > Sent: Friday, November 21, 2025 11:52 AM > To: [email protected] > Subject: [EXTERNAL] [BULK] Re: Queues problem in artemis > > CAUTION: This email originated from outside of NASA. Please take care > when clicking links or opening attachments. Use the "Report Message" > button to report suspicious messages to the NASA SOC. > > > > > Are these hosts all part of the same cluster? If so, messages produced on > one node will be delivered to consumers on another node assuming everything > is configured correctly. > > Can you provide any more details about the configuration of these hosts > and your overall use-case? > > > Justin > > On Fri, Nov 21, 2025 at 10:46 AM Gunawan, Rahman (GSFC-SEWP)[Halvik Corp] > via users <[email protected]> wrote: > > > I’ using below code to connect to Artemis 2.42.0: > > > > @Bean > > public ActiveMQConnectionFactory connectionFactory() throws Exception { > > ActiveMQConnectionFactory connectionFactory = null; > > > > > > > > String brokerUrls = > > > "tcp://hostname1:port1,tcp://hostname2:port2,hostname3:port3,tcp://hostname4:port4,tcp://hostname5:port5,tcp://hostname6:port6"; > > String connectionUrl = "(" + brokerUrls + > > ")?ha=true&retryInterval=2000&reconnectAttempts=-1"; > > > > connectionFactory = new ActiveMQConnectionFactory(connectionUrl, > > userName, password); > > > > // Client-specific settings > > > > connectionFactory.setReconnectAttempts(reconnectAttempt); > > connectionFactory.setRetryInterval(retryInterval); > > connectionFactory.setCallTimeout(callTimeout); > > > > return connectionFactory; > > } > > > > > > > > The problem is: producer connected to hostname 1 and put the messages > > to queue in hostname 1 but the consumer is connected to hostname 3 and > > listening to queue in hostname 3 so the messages are never being picked > up. > > > > > > > > How to solve this problem? > > > > > > > > Thanks > > > > > > > > > > > > > > > > *Rahman Gunawan* > > > > *SITSS Software Developer* > > > > NASA SEWP / SITSS > > > > HALV*I*K Corporation > > > > 7601 Ora Glen Dr, Greenbelt, MD 20770 > > > > C: 240.444.6003 > > O: 301.614.5257 > > > > [email protected] > > > > > > > > > > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > For further information, visit: https://activemq.apache.org/contact >
