Browse delayed messages

[rhinmass]

Hello,

I am using the delayed message property :

    message.setLongProperty("_HQ_SCHED_DELIVERY", System.currentTimeMillis()+10000)

when queueing messages.

I would like  to use a QueueBrowser to peek at the queue, but the QueueBrowser does not seem to see these messages that are in the scheduled state. 

Is there a way to see the messages that in the scheduled for delivery state?

Thanks for any help!!

Robin

[clebert.suconic]

You can use Management operations to look at those.

those are not delivered yet, right? Hence you can't look at those on the queue through the browsers. It doesn't make sense

[rhinmass]

Thanks Clebert.  How can I look at those message using management operations? I could only find javax.management.j2ee.statistics.getPendingMessageCount(),  but that is just the count.  Is there a way to peek at the actual message?

If so, can you point me at the class I would need to use?

[rhinmass]

OK, I just found QueueControl.listScheduledMessages().  I was looking in the javax.*, rather than the org.hornetq.*  But since "_HD_SCHED_DELIVERY" is not jms standard anyway, it makes sense I will need to go implementation-dependent.

[clebert.suconic]

As I said, With Scheduled Message you are saying send at a later time. The message didn't make to the JMS queues yet.

[rhinmass]

Clebert Suconic wrote:

You can use Management operations to look at those.

Which management operation can be used to look at the scheduled messages?

[rhinmass]

I figured out how to this:

    MBeanServer mBeanServer  = ManagementFactory.getPlatformMBeanServer();  

    SimpleString queueId = new SimpleString("jms.queue.MyQueue");   

    ObjectName on = ObjectNameBuilder.DEFAULT.getQueueObjectName(queueId, queueId);

    Map<String,Object>[] maps =

         (Map<String,Object>[])  mBeanServer.invoke(on, "listScheduledMessages", new Object[0], new String[0]);

    for (Map<String,Object> map : maps)

    {   

          long schedTime =  ((Long)map.get("_HQ_SCHED_DELIVERY")).longValue();

          System.out.println("message " + map.get("messageID") + "is scheduled for delivery on " + new Date(schedTime));

    }