在JMS中重新传递消息

Question

我正在读一条来自Solace的信息。我能够成功地阅读信息。假设我正在阅读一条消息，在侦听器线程上读取/处理消息时，应用程序崩溃。那我怎么能在那上面再读一遍那条信息呢。使用下面的代码，我无法再次阅读该消息。下面是我的配置

@JmsListener(destination = "myqueue", containerFactory = "jmsContainer", concurrency = "5-10")
    public void onMessage(Message msg) {
        
            String message;
            if (msg instanceof TextMessage) {
                message = ((TextMessage) msg).getText();
                LOG.info("In here START " +  message) ;
                Thread.sleep(60000); //I crash my app while thread is sleeping here
                LOG.info("In here END " +  msg.getJMSDestination() ) ;
                
            }
            

public class SolaceConfig {

    

    @Bean("solaceJndiTemplate")
    public JndiTemplate solaceJndiTemplate() {
        JndiTemplate solaceJndiTemplate = new JndiTemplate();
    
           // setting user name /password ommitted for brevity

            solaceJndiTemplate.setEnvironment(properties);
            
        
        return solaceJndiTemplate;
    }
    
    
    @Bean
    public JndiObjectFactoryBean solaceConnectionFactory(){
        
        JndiObjectFactoryBean solaceConnectionFactory = new JndiObjectFactoryBean();
        solaceConnectionFactory.setJndiTemplate(solaceJndiTemplate());
        solaceConnectionFactory.setJndiName(getJndiName());
        return solaceConnectionFactory;
    }
    


    @Primary
    @Bean
    public CachingConnectionFactory solaceCachedConnectionFactory(){
        CachingConnectionFactory solaceCachedConnectionFactory = new CachingConnectionFactory();
        solaceCachedConnectionFactory.setTargetConnectionFactory((ConnectionFactory)solaceConnectionFactory().getObject());
        solaceCachedConnectionFactory.setSessionCacheSize(10);
        return solaceCachedConnectionFactory;
    }


    @Bean
    public JmsTemplate jmsTemplate() {
        JmsTemplate jmsTemplate = new JmsTemplate(solaceCachedConnectionFactory());
        jmsTemplate.setDeliveryPersistent(true);
        jmsTemplate.setExplicitQosEnabled(true);
        return jmsTemplate;
    }
    

    @Bean
    public DefaultJmsListenerContainerFactory jmsContainer() {
        DefaultJmsListenerContainerFactory container = new DefaultJmsListenerContainerFactory();
        container.setConnectionFactory(solaceCachedConnectionFactory());
    //container.setSessionAcknowledgeMode(Session.AUTO_ACKNOWLEDGE);
        return container;
    }

Answer 1

使用DMLC时，应启用事务（设置sessionTransactited），以便回滚确认。

否则，请改用SimpleMessageListenerContainer。

参见javadocshttps://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/jms/listener/DefaultMessageListenerContainer.html

强烈建议将“会话事务”设置为“true”或指定外部“事务管理器”。有关确认模式和本机事务选项的详细信息，请参阅AbstractMessageListenerContainer javadoc，有关配置外部事务管理器的详细信息，请参阅AbstractPollingMessageListenerContainer javadoc。请注意，对于默认的“AUTO_ACKNOWLEDGE”模式，此容器在侦听器执行之前应用自动消息确认，在异常情况下不重新传递。