You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/10/16 12:59:32 UTC

svn commit: r585112 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java

Author: arnaudsimon
Date: Tue Oct 16 03:59:30 2007
New Revision: 585112

URL: http://svn.apache.org/viewvc?rev=585112&view=rev
Log:
Changed messageCount decrement

Modified:
    incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java

Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java?rev=585112&r1=585111&r2=585112&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/BasicMessageConsumer_0_10.java Tue Oct 16 03:59:30 2007
@@ -355,10 +355,10 @@
         return result;
     }
 
-      protected void preApplicationProcessing(AbstractJMSMessage jmsMsg) throws JMSException
+    void preDeliver(AbstractJMSMessage msg)
     {
         _messageCounter.decrementAndGet();
-        super.preApplicationProcessing(jmsMsg);   
+         super.preDeliver(msg);
     }
 
     public void setMessageListener(final MessageListener messageListener) throws JMSException
@@ -408,6 +408,10 @@
                 if( _messageCounter.get() > 0 )
                 {
                       o = _synchronousQueue.take();
+                }
+                else
+                {
+                    System.out.println("null");
                 }
             }
         }