Spring JMS（ActiveMQ）延迟消息传递

Question

@Autowired
private JmsTemplate jmsTemplate;

...
long deliveryDelay = ...;
this.jmsTemplate.setDeliveryDelay(deliveryDelay);
this.jmsTemplate.convertAndSend(
                    queue.getName(),
                    event);
...

java.lang.IllegalStateException: setDeliveryDelay requires JMS 2.0

@Component
public class MyMessageConverter implements MessageConverter {

...

@Override
public Message toMessage(Object eventObject, Session session) throws JMSException, MessageConversionException {

...
long deliveryDelay = ...;
objectMessage.setLongProperty(
                  ScheduledMessage.AMQ_SCHEDULED_DELAY,
                  deliveryDelay);
return objectMessage;
}
}

spring XML中的jmsTemplate定义：

<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
    <property name="connectionFactory" ref="cachingConnectionFactory" />
    <property name="messageConverter" ref="myMessageConverter" />
    <property name="sessionTransacted" value="true" />
</bean>

有人对问题有什么建议吗/关于如何实现延迟消息传递的其他想法？谢了！

Answer 1

评论给出了答案。默认情况下，计划消息支持被禁用。必须在broker XML配置文件中启用它，如文档页所述。

启用调度器支持的代理标记示例：

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}" schedulerSupport="true">

当然，您必须重新启动代理，才能使配置更改生效。然后，当您发送消息时，您需要添加JMS头，告诉代理您想要哪种类型的延迟。

message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, scheduledDelay);