如何强制重新传递未确认 jms 消息

Question

我继续阅读：http://www.javaworld.com/article/2074123/java-web-development/transaction-and-redelivery-in-jms.html?page=2

“通常，确认特定消息会确认会话接收到的所有先前消息”（在客户端确认模式下）

“消息重新传递不是自动的，但在某些情况下会重新传递消息”

我的问题：

1. 如何确保每次收到消息时都有一个新会话（但重复使用连接）？
2. 如何强制重新发送未确认消息？

我正在使用这个配置：

<bean id="jmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory"
            lazy-init="true">
            <property name="queueManager" value="${queueManager}" />
            <property name="hostName" value="${hostName}" />
            <property name="transportType" value="${transportType}" />
            <property name="port" value="${port}" />
            <property name="channel" value="${channel}" />
            <property name="SSLCipherSuite" value="${SSLCipherSuite}" />
      </bean>
<bean id="pooledConnectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory">
    <property name="maxConnections" value="10"/>
    <property name="maximumActive" value="100"/>
    <property name="connectionFactory" ref="jmsConnectionFactory"/>
</bean>
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
    <property name="connectionFactory" ref="pooledConnectionFactory"/>
    <property name="transacted" value="false"/>
 </bean>

<bean id="mqNonJmsDestRes" class="calypsox.tk.util.NonJmsMQQueueDestinationResolver" />

<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
      <property name="configuration" ref="jmsConfig" />
       <property name="acknowledgementModeName" value="CLIENT_ACKNOWLEDGE" />
       <property name="destinationResolver" ref="mqNonJmsDestRes" />
 </bean>

我使用骆驼处理器作为端点 bean 作为单例

Answer 1

您引用的那篇文章是 2002 年的。从那时起，所有基于 MQ 的系统都收到了大量的工作。在您的 AMQ PooledConnectionFactory 上，有一些设置可以控制连接在它们被破坏之前的持续时间以及遇到错误时应该做什么。我建议阅读一些较新的文档，因为在过去的 14 年中发生了很多变化。所以有些事情变得容易多了。

您还可以检查“org.apache.camel.component.jms.JmsComponent”上的异常侦听器来配置如何管理异常，如果当前选项不适合您的需要，甚至可以自己编写。