Hi All,
We are using a Stateless Session Bean to post messages to a HornetQ JMS Queue. Our requirement is such that once messages are dropped on to the queue they must remain on the queue for a minimum of 10 seconds before being consumed by a Message Driven Bean.
To achieve this functionality we tried to schedule the messages being dropped on to the queue like this.
Queue queue = HornetQJMSClient.createQueue(queueName);
MessageProducer producer = session.createProducer(queue);
Message message = session.createObjectMessage(myObject);
message.setLongProperty("_HQ_SCHED_DELIVERY", System.currentTimeMillis() + 10000);
producer.send(queue, message);
We have also placed a System.out.println on the first line inside the onMessage callback method of our Message Driven Bean. What we are seeing is that the onMessage method is being invoked immediately after a message is placed on the queue. In other words the message does not sit for 10 seconds on the queue. It is delivered immediately.
Are we doing something wrong? Is scheduling the means to achieve the business functionality of a 10 second wait, or is there some other way by which this requirement can be meet?
