You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2010/11/24 16:15:09 UTC
svn commit: r1038641 -
/activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
Author: tabish
Date: Wed Nov 24 15:15:09 2010
New Revision: 1038641
URL: http://svn.apache.org/viewvc?rev=1038641&view=rev
Log:
fix for: https://issues.apache.org/activemq/browse/AMQCPP-335
Modified:
activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
Modified: activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp?rev=1038641&r1=1038640&r2=1038641&view=diff
==============================================================================
--- activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp (original)
+++ activemq/activemq-cpp/branches/activemq-cpp-3.2.x/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp Wed Nov 24 15:15:09 2010
@@ -909,7 +909,7 @@ void ActiveMQConsumer::rollback() throw(
}
if( this->redeliveryPolicy->getMaximumRedeliveries() != RedeliveryPolicy::NO_MAXIMUM_REDELIVERIES &&
- lastMsg->getRedeliveryCounter() > this->redeliveryPolicy->getMaximumRedeliveries() ) {
+ lastMsg->getMessage()->getRedeliveryCounter() > this->redeliveryPolicy->getMaximumRedeliveries() ) {
// We need to NACK the messages so that they get sent to the DLQ.
// Acknowledge the last message.