Author: tabish
Date: Fri Oct 23 23:26:35 2009
New Revision: 829278
URL: http://svn.apache.org/viewvc?rev=829278&view=rev
Log:
Handle an extra error condition.
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp?rev=829278&r1=829277&r2=829278&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/core/ActiveMQConsumer.cpp Fri
Oct 23 23:26:35 2009
@@ -293,6 +293,10 @@
return Pointer<MessageDispatch>();
}
+ } else if( dispatch->getMessage() == NULL ) {
+
+ return Pointer<MessageDispatch>();
+
} else if( dispatch->getMessage()->isExpired() ) {
beforeMessageIsConsumed( dispatch );
|