ActiveMQ在Spring Boot中延迟消息传递

Question

我的问题与Spring JMS（ActiveMQ）延迟传递消息非常相似，但与Spring boot自动配置程序更相关

我试图使用jmsTemplate.setDeliveryDelay方法，但它抛出了一个java.lang.IllegalStateExcue： setDeliveryDelay需要JMS 2.0

我试着从他那里找到合适的房产http://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html但找不到broker schedulerSupport选项。

目前，我的申请。属性为空，我的JmsListenerContainerFactory定义如下

@Bean
public JmsListenerContainerFactory<?> myFactory(ConnectionFactory connectionFactory,
                                                DefaultJmsListenerContainerFactoryConfigurer configurer) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();

    configurer.configure(factory, connectionFactory);
    return factory;
}

而我的pom只包含

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

使用1.4.1中的Spring-boot-starter-父级。发布

问题是：是否可以使用SpringBoot配置将schedulerSupport设置为true？

如果需要，这是我的寄件人

public void send(String message) {
    System.out.println("Im sending this message " + message);
    jmsTemplate.setDeliveryDelay(5000);
    jmsTemplate.convertAndSend(Beans.QUEUE_NAME, message);
}

和接受者

@JmsListener(destination = Beans.QUEUE_NAME, containerFactory = "myFactory")
public void receiveMessage(String message) {
    System.out.println("Received this message <" + message + ">");
}

提前谢谢

更新：我试着把它放在消息属性中，比如文档中http://activemq.apache.org/delay-and-schedule-message-delivery.html，但它不起作用

@Bean
public MessageConverter messageConverter() {
    MessageConverter converter = new MessageConverter(){
        @Override
        public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
            if (!(object instanceof MyPojo)) {
                throw new MessageConversionException("not agreed Pojo!");
            }
            MyPojo pojo = (MyPojo) object;

            Message message = session.createTextMessage(pojo.getMessage());
            message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, pojo.getScheduledWait());
            return message;
        }
        @Override
        public Object fromMessage(Message message) throws JMSException, MessageConversionException {
            return message;
        }
    };
    return converter;
}

Answer 1

我不知道这是否是作弊，但对我来说，解决问题的方法是将启动器从activemq更改为artemis(https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-artemis)

显然，spring默认将Artemis配置为JMS 2.0接口。这样您就可以访问setDeliveryDelay方法。

Answer 2

该模板试图调用JMS 2.0交付延迟方法，但ActiveMQ客户端和代理只支持JMS 1.1，因此您将收到此错误。通过使用此处定义的值在消息中设置消息属性，可以将ActiveMQ支持用于计划交付。

目前还不完全清楚如何从Spring boot启用调度器，但我猜您需要提供自己的代理URI来启用它，比如：

broker:(tcp://localhost:61616)?persistent=true&useJmx=false&schedulerSupport=true