如何强制取消jms消息的重新传递

Question

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

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

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

我的问题是：

1. 如何确保每次收到消息时都有一个新会话（但重复使用连接）

我正在使用此配置：

<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>

我使用camel处理器作为endpointbean作为单例

Answer 1

你引用的那篇文章是2002年的。从那以后，所有基于MQ的系统都接受了大量的工作。在你的AMQ池连接工厂上，有一些设置来控制你的连接在被销毁之前持续多长时间，以及如果遇到错误你应该怎么做。我建议阅读一些新的留档，因为在过去的14年里有很多变化。所以有些事情变得容易多了。

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