SpringBoot：发送JMS消息

Question

我想使用SpringBoot向ActiveMQ队列发送消息。应用程序应在发送后终止，但仍保持活动状态。

这是我的申请代码：

@SpringBootApplication
public class TestJmsClient implements CommandLineRunner {

    private static final String QUEUE_NAME = "myQueue";

    @Autowired
    private JmsTemplate jmsTemplate;

    public static void main(String[] args) {
        new SpringApplicationBuilder(TestJmsClient.class).bannerMode(Mode.OFF).run(args);
    }

    @Bean
    public MessageConverter jacksonJmsMessageConverter() {
        MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
        converter.setTargetType(MessageType.BYTES);
        converter.setTypeIdPropertyName("_type");
        return converter;
    }

    @Override
    public void run(String... args) throws Exception {
        jmsTemplate.convertAndSend(QUEUE_NAME, new MyObject());
    }
}

在没有任何父节点的情况下使用以下依赖项（Maven）：

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

<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
</dependency>

和一行应用程序。属性：spring。activemq。代理url=故障转移：(tcp://localhost:61616)

消息已发送到队列，但应用程序未停止。线程转储告诉我，ActiveMQ传输：tcp://localhost/127.0.0.1:61616线程正在运行。

我是否需要不同的连接工厂？或者，我可以在发送消息后立即终止应用程序吗？

注意：如果没有JMS内容，应用程序将终止。注意：我使用的是标准的ActiveMQ安装。

感谢：）




Answer 1

这就是解决方案：

@Bean
public ConnectionFactory connectionFactory() {
    ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
    return connectionFactory;
}

Answer 2

匿名用户

您可以在运行程序退出后关闭（）应用程序上下文...

new SpringApplicationBuilder(TestJmsClient.class).bannerMode(Mode.OFF).run(args).close();