[ https://issues.apache.org/jira/browse/AMQNET-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15014718#comment-15014718 ]
ASF subversion and git services commented on AMQNET-513: -------------------------------------------------------- Commit 1715303 from [~tabish121] in branch 'ActiveMQ/trunk' [ https://svn.apache.org/r1715303 ] https://issues.apache.org/jira/browse/AMQNET-513 Preserve the rollback cause when poisoning a message. > Exception message is not propagated in case of consumption failure > ------------------------------------------------------------------ > > Key: AMQNET-513 > URL: https://issues.apache.org/jira/browse/AMQNET-513 > Project: ActiveMQ .Net > Issue Type: Bug > Components: NMS > Affects Versions: 1.6.2, 1.7.0, 1.7.1 > Reporter: Maxim Cherednik > Assignee: Jim Gomes > > After moving from version 1.6.2 to 1.7 we lost some functionality we were > relying on. > When we were failing to process message 6 times, it was moved to the > Activemq.DLQ and the property dlqDeliveryFailureCause was filled with > Exception message which was raised during the processing. > After version update - the exception message is not propagated. This message > instead: > javax.jms.JMSException: Exceeded RedeliveryPolicy limit: 6 > Maybe there are other way to track which client failed to process message and > why(exception message) ? > Code sample: > {code:title=Consumer.cs|borderStyle=solid} > static void Consume() > { > var brokerUri = ""; > var clientId = "test"; > var connFactory = new ConnectionFactory(brokerUri, clientId); > _connection = connFactory.CreateConnection(); > _connection.ExceptionListener += _connection_ExceptionListener; > _connection.ConnectionResumedListener += > _connection_ConnectionResumedListener; > _connection.ConnectionInterruptedListener += > _connection_ConnectionInterruptedListener; > var session = > _connection.CreateSession(AcknowledgementMode.AutoAcknowledge); > var q = session.GetTopic("TopicName"); > var queue = session.CreateDurableConsumer(q, clientId, null, > false); > queue.Listener += msgsConsumer_Listener; > _connection.Start(); > } > static void msgsConsumer_Listener(IMessage message) > { > Console.WriteLine("Consumed: " + message.NMSMessageId); > > throw new InvalidOperationException("Maxxxxxxx", new > Exception("Maxxxxxxx")); > } > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)