Enterprise Integration Zone is brought to you in partnership with:

Alex is working as a software developer since 1997. He coded many languages and started coding Java in 2000. As a person that likes to share his experience with others he started his professional blog http://alexr.blog.com Alexander has posted 5 posts at DZone. View Full User Profile

Sending delayed JMS Messages

09.22.2010
| 22417 views |
  • submit to reddit

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

The scheduled task may be implemented as resource adapter (JCA):
BootstrapContext ctx;
ctx.getWorkManager().createTimer(). schedule(new DelayedMessageTimerTask(msg),
new Date(now + delay))
This is not ideal solution. It is OK for relatively small number of messages and non persisted JMS destinations. Improvements of this solution are beyond the scope of this article.  

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.


Published at DZone with permission of its author, Alexander Radzin.

(Note: Opinions expressed in this article and its replies are the opinions of their respective authors and not those of DZone, Inc.)

Tags: