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.
