Re: ActiveMQ: Advisory for MessageConsumed

Hi Gary, Thanks for replying. I have logged a Jira for the issue: https://issues.apache.org/jira/browse/AMQ-3361 thanks -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-Advisory-for-MessageConsumed-tp3547010p3578728.html Sent from the ActiveMQ - User mailing list

Re: ActiveMQ: Advisory for MessageConsumed

Hi Brendan, I have set the listener container to session transacted. When an exception is thrown in the listener, then spring rolls back the transaction. But the problem is that an advisory message is still sent to the consumed advisory topic( before the rollback). Thus giving an incorrect indica

Re: ActiveMQ: Advisory for MessageConsumed

Hi Aneesh There are many kinds of advisory messages that u can set up. Check this site out:- http://activemq.apache.org/advisory-message.html These are messages that activeMQ sends to specific topics about information on the producer/consumer etc. All you need to do is update the activemq conf f

Re: ActiveMQ: Advisory for MessageConsumed

Hi Dejan Thanks for replying. So it seems advisory for consumed isnt going to serve the purpose of tracking consumed messages. Is there any way of approach that might help in tracking successfully consumed messages... Thanks alot -- View this message in context: http://activemq.2283324.n4.nabb

ActiveMQ: Advisory for MessageConsumed

Hello, I have a requirement to get the messages that have been successfully consumed. My application is using the DefaultMessageListenerContainer of spring for the listeners. I have enabled the advisoryForConsumed. My Queue name is 'Test' and it has a listener . Correspondingly there is an adv

Re: ActiveMQ 5.5: Not able to get the DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY value

Sorry forgot to attach the log file, resending message with a log file. Hi Gary, I have enabled the advisoryForConsumed. My Queue name is 'Test' and it has a listener . Correspondingly there is an advisory topic called 'ActiveMQ.Advisory.MessageConsumed.Queue.Test' and this has its own listen

Re: ActiveMQ 5.5: Not able to get the DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY value

Hi Gary, I have enabled the advisoryForConsumed. My Queue name is 'Test' and it has a listener . Correspondingly there is an advisory topic called 'ActiveMQ.Advisory.MessageConsumed.Queue.Test' and this has its own listener. My use case to illustrate my problem is below:- 1) Send a message to Te

Re: ActiveMQ 5.5: Not able to get the DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY value

Hi Gary, I might have another problem that might surface due to exceptions not being sent back to ActiveMQ. I use an advisory topic to know if the message was sucessfully consumed or did an error inccur. Thus my queue 'Test' has an advisory called 'ActiveMQ.Advisory.MessageConsumed.Queue.Test'.

Re: ActiveMQ 5.5: Not able to get the DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY value

Hi Gary Thanks alot for your help and time. Really appreciate it. Will use the exception listerner apprach. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-5-5-Not-able-to-get-the-DLQ-DELIVERY-FAILURE-CAUSE-PROPERTY-value-tp3492931p3498091.html Sent from the Act

Re: ActiveMQ 5.5: Not able to get the DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY value

Hi Gary Thanks alot. I now understand that the spring framework is catching the exception. I used the SimpleMessageListenerContainer as you advised. But again did not get the DLQ exception string. I think the same thing is happening in this container as well. I have attached the activemq and wrap

Re: ActiveMQ 5.5: Not able to get the DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY value

Hi Gary Thanks for replying. I have attached the log file with trace level for the same use case. Also i have attached my listener class. Hope this helps. Thanks alot http://activemq.2283324.n4.nabble.com/file/n3496132/activemq.txt activemq.txt http://activemq.2283324.n4.nabble.com/file/n349613

Re: ActiveMQ 5.5: Not able to get the DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY value

Hi Gary Thanks alot for replying. I am using the tcp protocol with the following broker url:- tcp://localhost:61616 My application is using the Spring Framework. And i am using the DefaultMessageListenerContainer for the listeners. I have attached a log file that captures the following use c