Sending delayed JMS Messages
by
·
Join the DZone community and get the full member experience.
Join For FreeVery often I have had to implement features that have to do something asynchronously in a minute, day, or at 5PM next Monday. Every time I did this, I implemented some serialization mechanism (typically based on DB) and some scheduled task that runs periodically, checks the table and runs tasks that should be executed now.
Sometimes more generic tools were used, for example, Quartz. I couldn't implement such tasks using JMS : the reason is that JMS API does not allow sending delayed messages, i.e. messages that will not be received by subscriber or receiver immediately. Occasionally I found that some JMS implementations have a proprietary implementation for delayed messages. I decided to perform some searches and aggregate this information into one place. Here is a list of the most popular JMS implementations (see wikipedia):
- Apache ActiveMQ
- Apache Qpid
- FUSE Message Broker (enterprise ActiveMQ)
- Mantaray a P2P JMS implementation
- OpenJMS, from The OpenJMS Group
- JBoss Messaging from JBoss
- HornetQ from JBoss
- JORAM, from the OW2 Consortium
- Open Message Queue, from Sun Microsystems
- Sun Java System Message Queue, from Sun Microsystems, supported version of Open Message Queue
- Rabbit MQ
Because the JMS API does not define an interface for delayed messages most SMS providers that support this feature implemented it using message properties. You just have to say something like msg.setLongProperty(“DELAY”, delay). Some implementations require casting to a specific class and invocation of a proprietary method. The following table summarizes the differences between implementations of different SMS providers I found.
| JMS provider | Implementation |
| Oracle AQ | msg.setIntProperty(“JMS_OracleDelay”, delay); |
| JBoss | msg.setLongProperty(“JMS_JBOSS_SCHEDULED_DELIVERY”, now + delay); |
| ActiveMQ | msg.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, delay); |
| OpenJMS | ((org.exolab.jms.message.MessageImpl)msg).setJMSXRcvTimestamp(now + delay); |
| BEA Weblogic | queueConnection = queueConnectionFactory.createQueueConnection(); QueueSession queueSession = queueConnection.createQueueSession(true, 0); QueueSender queueSender = queueSession.createSender(queue); ObjectMessage jmsMsg = queueSession.createObjectMessage(message); //Casts queueSender to weblogic.jms.extensions.WLMessageProducer interface and set delivery time ((WLMessageProducer) queueSender).setTimeToDeliver(timeToDeliver); queueSender.send(jmsMsg); |
Do we have solution for JMS providers that do not have native support of delayed message delivery? Yes, we do. I would like to suggest the following solution.
Send message to special queue. Let’s call it DELAYED_QUEUE. Add the following special properties to the delayed message:
- JMS_DESTINATION that contains name of queue or topic where this message should be finally delivered.
- DELIVERY_TIME that contains time stamp in milliseconds (now + delay).
For each enqued delayed message create a scheduled task that that will run once when message should be delivered. This scheduled task will create a JMS receiver with a selector that looks like DELIVERY_TIME < now (where now is the timestamp), receives all expired messages and sends them to the real JMS destination using property JMS_DESTINATION.
BootstrapContext ctx;
ctx.getWorkManager().createTimer(). schedule(new DelayedMessageTimerTask(msg),
new Date(now + delay))
Conclusions
Most popular JMS implementations support delayed delivery of messages. Even if this feature is not supported we can always implement it using additional queue and scheduled task.
Opinions expressed by DZone contributors are their own.
Comments