我使用apachecamel和spring从java服务发送消息。我需要重置jms连接，以防在exchange发生任何错误。我使用下面的代码来实现我的目标。

try
{
    producerTemplate.sendBody(endPoint, bytes);
}
catch (final RuntimeCamelException exception)
{
    LOGGER.error("Exception occured in sendBody", exception.getMessage(), exception);
    handleError(); // handle error here.
}

在camel上下文中，我用exception listener定义了cachingconnectionfactory，并使reconnectonexception=true

<bean id="testConnectionFactory" class="org.apache.qpid.jms.JmsConnectionFactory">
    <property name="username" value="${user.name}" />
    <property name="password" value="${user.password}" />
    <property name="clientID" value="${host.address}" />
    <property name="remoteURI"
        value="amqp://${host.address}:${host.port}?jms.clientID=${host.address}?jms.username=${user.name}&amp;jms.password=${user.password}&amp;jms.redeliveryPolicy.maxRedeliveries=${message.retry.count}&amp;amqp.saslMechanisms=PLAIN" />
</bean>

<bean id="testCachingConnectionFactory"
    class="org.springframework.jms.connection.CachingConnectionFactory">
            <property name="exceptionListener" ref="testCachingConnectionFactory" />
            <property name="targetConnectionFactory" ref="testConnectionFactory" />
            <property name="reconnectOnException" value="true" />
</bean>

在我的例子中，jmssecurityexception是从try块的下行抛出的

producerTemplate.sendBody(endPoint, bytes)

执行在catch块内进行，但从未调用singleconnectionfactory的onexception（），即使定义了exceptionlistener。其思想是调用resetconnection（）（在onexception内部）来重置jms连接。