activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sagi Mann <>
Subject Re: Reliable request/response
Date Tue, 02 Jan 2007 16:26:25 GMT

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 =
MessageConsumer c = session.createConsumer(exp);
c.setMessageListener(this); // my onMessage method simply outputs the

My 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?

Marlon Santos wrote:
> Hi,
> Using 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:
Sent from the ActiveMQ - User mailing list archive at

View raw message