ActiveMQ Artemis broker上未发布“正在传递”状态的消息

Question

因此，我尝试在代理或客户端连接字符串 (tcp://host1:61616,tcp://host2:61616)上设置，ha=true&connectionttl=60000&reconnection尝试=-1)，但这似乎没有任何效果，因为连接不会关闭，消息也不会释放。为了使用消息，我使用带有cachingconnectionFactory的Artemis JMS Spring客户机，但也尝试了JMSpoolconnectionFactory。

<bean id="connectionFactory"
    class="org.springframework.jms.connection.CachingConnectionFactory">
    <property name="targetConnectionFactory">
          <bean  class="org.apache.activemq.artemis.jms.client.ActiveMQConnectionFactory">
                 <property name="user" value="${spring.artemis.user}" />
                 <property name="password" value="${spring.artemis.password}" />
                 <property name="brokerURL" value="${spring.artemis.brokerUrl}" />
           </bean>
     </property>
     <property name="cacheConsumers" value="false"/>
</bean>

<int-jms:message-driven-channel-adapter
     connection-factory="connectionFactory"
     destination="myQueue"
     message-converter="messageConverter"
     channel="inputChannel"
     concurrent-consumers="${processing.poolsize}"
     max-concurrent-consumers="${max.processing.poolsize}"
     error-channel="errorChannel"
     acknowledge="transacted"
/>

解决这个问题的唯一方法似乎是重新启动消费者应用程序，以解锁消息，但这不是理想的选择。

如何解决此问题？有没有一种不用人工干预、不用重启消费APP就能发布消息的方法？

Answer 1

在CachingConnectionFactory中使用变量并发可能是问题所在。

当一个“空闲”使用者返回到缓存时，代理不知道使用者不是活动的，仍然向它发送消息。

缓存工厂实际上只需要在生产者端(JMSTemplate)，以避免为每次发送创建连接和会话。