ActiveMQ delayed delivery of messages in Spring Boot

My question is really similar to Spring JMS(ActiveMQ) delayed delivery of messages but more correlated to the spring-boot auto configurer

I'm trying to use the

method, but it throws a

I tried to find the right property from http://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html but couldn't find the broker schedulerSupport option.

Currently, my application.properties is empty, and my JmsListenerContainerFactory is defined as follows

@Bean

public JmsListenerContainerFactory<?> myFactory(ConnectionFactory connectionFactory,

                                                DefaultJmsListenerContainerFactoryConfigurer configurer) {

    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();



    configurer.configure(factory, connectionFactory);

    return factory;

}

And my pom only contains

    <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>

With the spring-boot-starter-parent in 1.4.1.RELEASE

The question is: Is it possible to set the schedulerSupport to true using SpringBoot configurations?

In case it's needed, here are my Sender

public void send(String message) {

    System.out.println("Im sending this message " + message);

    jmsTemplate.setDeliveryDelay(5000);

    jmsTemplate.convertAndSend(Beans.QUEUE_NAME, message);

}

and Receiver

@JmsListener(destination = Beans.QUEUE_NAME, containerFactory = "myFactory")

public void receiveMessage(String message) {

    System.out.println("Received this message <" + message + ">");

}

thanks in advance

---

Update: I tried put it in the message properties, like the documentation http://activemq.apache.org/delay-and-schedule-message-delivery.html , but it doesn't work

@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;

}