当application server突然停止时，丢失带有Spring JMS和ActiveMQ的JMS消息

Question

我有一个Spring JMS应用程序，它有一个JMS侦听器，在应用程序启动时连接到活动的MQ队列。这个JMS侦听器是an应用程序的一部分，该应用程序接收消息，用内容丰富消息，然后将消息传递给同一个ActiveMQ代理上的主题。

SessionTransact设置为true。我没有执行任何数据库事务，所以我没有@Transactional设置。从我所读到的内容来看，SessionTransact属性围绕JMS侦听器的receive方法设置本地事务，因此在事务完成之前不会将消息从队列中拉出。我已经使用本地ActiveMQ实例和本地tomcat容器对此进行了测试，它按预期工作。

但是，当我部署到我们的PERF环境并重试相同的测试时，我注意到服务器关闭时当前正在运行的消息是在完成receive方法之前从队列中提取的。

我想知道的是，是否有任何明显的东西，我应该寻找？是否有某些JMS标头会导致这种行为发生？请让我知道，如果有更多的信息，我可以提供。

我在运行Java8的Tomcat7容器上使用Spring 4.1.2和Apache ActiveMQ 5.8.0版本。

更新-添加我的Java JMS配置。请注意，为了清晰起见，我将PERF属性文件中的内容替换到了相关区域。

    @Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() throws Throwable {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory());
    factory.setMaxMessagesPerTask(-1);
    factory.setConcurrency(1);
    factory.setSessionTransacted(Boolean.TRUE);
    return factory;
}

@Bean
public CachingConnectionFactory connectionFactory(){
    RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();

    redeliveryPolicy.setInitialRedeliveryDelay(1000);
    redeliveryPolicy.setRedeliveryDelay(1000);
    redeliveryPolicy.setMaximumRedeliveries(6);
    redeliveryPolicy.setUseExponentialBackOff(Boolean.TRUE);
    redeliveryPolicy.setBackOffMultiplier(5);

    ActiveMQConnectionFactory activeMQ = new ActiveMQConnectionFactory(environment.getProperty("queue.username"), environment.getProperty("queue.password"), environment.getProperty("jms.broker.endpoint"));
    activeMQ.setRedeliveryPolicy(redeliveryPolicy);
    activeMQ.setPrefetchPolicy(prefetchPolicy());

    CachingConnectionFactory cachingConnectionFactory = new CachingConnectionFactory(activeMQ);
    cachingConnectionFactory.setCacheConsumers(Boolean.FALSE);
    cachingConnectionFactory.setSessionCacheSize(1);
    return cachingConnectionFactory;
}

@Bean
public JmsMessagingTemplate jmsMessagingTemplate(){
    ActiveMQTopic activeMQ = new ActiveMQTopic(environment.getProperty("queue.out"));

    JmsMessagingTemplate jmsMessagingTemplate = new JmsMessagingTemplate(connectionFactory());
    jmsMessagingTemplate.setDefaultDestination(activeMQ);

    return jmsMessagingTemplate;
}

protected ActiveMQPrefetchPolicy prefetchPolicy(){
    ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy();
    int prefetchValue = 0; 
    prefetchPolicy.setQueuePrefetch(prefetchValue);
    return prefetchPolicy;
}

谢谢，

胡安