CODEWITHSUNDEEP
javaspringjmsactivemq-classicspring-jms
Ayelet
Ayelet

Reputation: 1743

Spring JMS(ActiveMQ) delayed delivery of messages

We're trying to set a delay on some JMS messages, so that a message will only be added to the queue/ received by the listener after x time. So far we've tried 2 approaches that didn't work.

1) According to the spring documentation, we can set the delivery delay on the JMSTemplate. This is the sample code we tried:

@Autowired
private JmsTemplate jmsTemplate;

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

However, we get the following exception, even though our spring jms version is 4.0.5:

java.lang.IllegalStateException: setDeliveryDelay requires JMS 2.0

2) We also tried setting the delay on the message itself, but it looks like the delay was ignored, and the message was delivered immediately anyway.

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

The jmsTemplate definition in the spring xml:

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

Does anyone has any suggestions on what the problems are / other ideas on how to achieve delayed messaging? Thanks!

Upvotes: 11

Views: 22818

Answers (9)

kerner1000
kerner1000

Reputation: 3558

You can also define a new, delaying JmsTemplate which you can autowire where needed:

@Bean
public JmsTemplate jmsTemplate(){
    JmsTemplate jmsTemplate = new JmsTemplate();
    jmsTemplate.setConnectionFactory(connectionFactory());
    return jmsTemplate;
}

@Bean
public JmsTemplate delayingJmsTemplate(){
    JmsTemplate jmsTemplate = new JmsTemplate();
    jmsTemplate.setDeliveryDelay(1000);
    jmsTemplate.setConnectionFactory(connectionFactory());
    return jmsTemplate;
}

...

@Autowired
private JmsTemplate jmsTemplate;

@Autowired
private JmsTemplate delayingJmsTemplate;

Upvotes: 0

neaGaze
neaGaze

Reputation: 1461

The JMS 2.0 is not supported in the activemq package. Try using artemis instead. Try replacing the package name from

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

into

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-artemis</artifactId>
        <version>1.5.6.RELEASE</version> 
    </dependency>

and also add in the application.properties

    spring.artemis.mode=native
    spring.artemis.host=localhost
    spring.artemis.port=61616
    spring.artemis.user=admin
    spring.artemis.password=admin

Upvotes: 0

Tim Bish
Tim Bish

Reputation: 18376

The comments give the answer. By default scheduled message support is disabled. You must enabled it in the broker XML configuration file as mentioned on the documentation page.

An example Broker tag with scheduler support enabled:

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

You must of course restart the broker in order for configuration changes to take affect. Then when you send a message you need to add the JMS headers that tell the broker what type of delay you want.

message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, scheduledDelay);

Upvotes: 8

Ray
Ray

Reputation: 11

  1. I have added schedulerSupport=true in active mq configuration xml. Please dont forget to restart the active mq server after configuration changes. Once you restart and login to "Scheduled" tab on admin console of activemq, you would see scheduled message details.

  2. jmsTemplate.setDeliveryDelay did not work for me so I added the below piece of code : used 

    jmsTemplate.convertAndSend(queueName, object, new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws JMSException {
                message.setIntProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, scheduledDelay);
                return message;
            }
        });

Please note : It was not working for me in the beginning. But what was needed was an restart on activeMQ server to reflect the changes in config

Upvotes: 0

dassum
dassum

Reputation: 5113

Two things needs to be done to resolve this.

  • By default scheduled message support is disabled. We must enabled it in the broker XML configuration file.

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

  • Set the delay before sending the message.

    public void send(Object object) {
    log.info("put <" + object + ">");
    jmsTemplate.convertAndSend(QUEUE_NAME, object, m -> {
       m.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 10000);
       return m;
    });
}

Upvotes: 1

Nurlan Rysbaev
Nurlan Rysbaev

Reputation: 1

Documentation http://activemq.apache.org/delay-and-schedule-message-delivery.html

Example: after 10 sec received message by consumer

public void send(Object object) {
    log.info("put <" + object + ">");
    jmsTemplate.convertAndSend(QUEUE_NAME, object, m -> {
        m.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 10000);
        return m;
    });
}

Upvotes: 0

mr.tianshu
mr.tianshu

Reputation: 11

broker-url: vm://embedded?broker.persistent=true&broker.useShutdownHook=false&broker.schedulerSupport=true

Upvotes: 0

Barca
Barca

Reputation: 1

  jmsTemplate.convertAndSend(destination, message, new MessagePostProcessor() {
            @Override
            public Message postProcessMessage(Message message) throws JMSException {
                message.setIntProperty("JMS_OracleDelay", 200);
                return message;
            }
        });

Upvotes: 0

oleh.kovaliuk
oleh.kovaliuk

Reputation: 157

Also according to method from ActiveMQ BrokerService class you should configure persistence to have ability to use scheduler functionality.

public boolean isSchedulerSupport() {
    return this.schedulerSupport && (isPersistent() || jobSchedulerStore != null);
}

Upvotes: 0

Related Questions