Hi, I can't seem to catch any expiration messages.
I've done as the URL suggested:
Destination q = session.createQueue("my.queue");
Destination exp =
AdvisorySupport.getExpiredQueueMessageAdvisoryTopic((ActiveMQDestination)q);
MessageConsumer c = session.createConsumer(exp);
c.setMessageListener(this); // my onMessage method simply outputs the
messageMy producer sends a message (TTL=5000) from a different session, and I expected the consumer above to "catch" the expiration notice, but it doesn't.. Using jconsole, I can see my message arriving at the queue and stay there (shouldn't it be removed after expiration?). Am I doing anything wrong? Thanks, Marlon Santos wrote: > > Hi, > > Using http://activemq.org/site/advisory-message.html Advisory Messages > can be of great help... > > Regards, > Marlon > > > > Sagi Mann wrote: >> >> Hi, >> From the reliability discussions of JMS, I was still unable to figure out >> how to implement the following using ActiveMQ: >> >> A client (producer) simultaneously instructs 10 servers (consumers) to >> perform some work by sending a message to each server's message queue. >> Now, the client needs some sort of confirmation: either a certain server >> completed the work -OR- some message did not reach the server and >> expired. Needsless to say these confirmations are handled asynchronously. >> >> Does JMS/ActiveMQ provide some acknowledgement of these events? (afaik, >> session acknowledgement mode does not reach the sender). I know I can >> implement some temp queue for the replies, but that won't notify me of >> expired messages! >> >> thanks... >> > > -- View this message in context: http://www.nabble.com/Reliable-request-response-tf2890291.html#a8126393 Sent from the ActiveMQ - User mailing list archive at Nabble.com.
