在ActiveMQ与Wildfly集成时,可能会遇到多个消费者订阅相同的队列并收到消息的问题。这会导致消息被重复处理或其他不良行为。以下是一种解决方法,可以避免这种情况发生。
true
true
PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory();
pooledConnectionFactory.setConnectionFactory(new ActiveMQConnectionFactory(brokerUrl));
CachingConnectionFactory connectionFactory = new CachingConnectionFactory(pooledConnectionFactory);
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(destination);
List connections = new ArrayList<>();
List sessions = new ArrayList<>();
List consumers = new ArrayList<>();
int numConsumers = 3;
for (int i=0; i