Hi team. Please, help me with the following question.
This is my current configuration:
* @Bean public ConnectionFactory activeMQConnectionFactory() { String
brokerUrl = "(tcp://somehost1.com:61617
<http://somehost1.com:61617>,tcp://somehost2.com:61617)?ha=true&sslEnabled=true";
final ActiveMQConnectionFactory connectionFactory = new
ActiveMQConnectionFactory(brokerUrl); connectionFactory.setUser("admin");
connectionFactory.setPassword("admin");
connectionFactory.setRetryInterval(1000);
connectionFactory.setReconnectAttempts(30); return connectionFactory; }
@Bean(destroyMethod = "stop") @Primary public ConnectionFactory
jmsPoolConnectionFactory(final ConnectionFactory activeMQConnectionFactory)
{ final JmsPoolConnectionFactory jmsPoolConnectionFactory = new
JmsPoolConnectionFactory();
jmsPoolConnectionFactory.setConnectionFactory(activeMQConnectionFactory);
jmsPoolConnectionFactory.setMaxConnections(10); return
jmsPoolConnectionFactory; }*
This are my dependencies:
*<dependency> <groupId>org.apache.activemq</groupId>
<artifactId>artemis-jakarta-client</artifactId> <version>2.43.0</version>
</dependency> <dependency> <groupId>org.messaginghub</groupId>
<artifactId>pooled-jms</artifactId> <version>3.1.7</version> </dependency>*
When I add JmsPoolConnectionFactory bean my active consumers stop receiving
messages on failover when an active node fails. Everything works fine
without JmsPoolConnectionFactory meaning that consumers continue receiving
messages on failover.
Is it expected? Is there a way to handle it?
Thanks! Best regards.
