@JmsListener 上的 ActiveMq 事务

Question

我尝试让具有 activeMq 代理的 Jms 消费者有一个 "transactional" 确认。我想使用 spring 启动应用程序。

我读到我需要 JTA 事务，但我不知道如何开始。

我的主要class:

@SpringBootApplication
@EnableJms
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

我的消费者：

@Component
public class ReceiveMessage {
    @JmsListener(destination = "${jms.queue.destination}")
    public void receiveMessage(final String msg) throws Exception {
        System.out.println("Received:" + msg);
    }
}

我的 pom.xml 依赖关系：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-activemq</artifactId>
    </dependency>
</dependencies>

我必须做什么？

Answer 1

更新您的消费者：

@Component
public class ReceiveMessage {
    @JmsListener(destination = "${jms.queue.destination}", containerFactory = "jmsListenerContainerFactory")
    public void receiveMessage(final String msg) throws Exception {
        System.out.println("Received:" + msg);
    }
}

添加这些豆子：

@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactory(
        ConnectionFactory connectionFactory,
        DefaultJmsListenerContainerFactoryConfigurer configurer) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    configurer.configure(factory, connectionFactory);
    factory.setTransactionManager(transactionManager());
    return factory;
}

@Bean
public PlatformTransactionManager transactionManager() {
    JmsTransactionManager transactionManager = new JmsTransactionManager();
    transactionManager.setConnectionFactory(jmsConnectionFactory());
    return transactionManager;
}

@Bean
public QueueConnectionFactory jmsConnectionFactory() {
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:5672");
    return connectionFactory;
}

@JmsListener 上的 ActiveMq 事务

ActiveMq transaction on @JmsListener

java

spring-jms

spring-boot