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

[arnaudsimon]

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