activemq-commits mailing list archives

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 );