Re: Reliable request/response

[Sagi Mann <sa...@gmail.com>]

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
message

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