svn commit: r637084 - /incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java

[ritchiem]

Author: ritchiem
Date: Fri Mar 14 05:45:59 2008
New Revision: 637084

URL: http://svn.apache.org/viewvc?rev=637084&view=rev
Log:
QPID-853 : Use the result of processMethod (match) to decide if we have the 
right frame.

Modified:
    
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java

Modified: 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=637084&r1=637083&r2=637084&view=diff
==============================================================================
--- 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
 (original)
+++ 
incubator/qpid/branches/M2.1/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
 Fri Mar 14 05:45:59 2008
@@ -2294,9 +2294,12 @@
             public boolean processMethod(int channelId, AMQMethodBody frame) 
//throws AMQException
             {
                 boolean matches = super.processMethod(channelId, frame);
-                QueueDeclareOkBody declareOk = (QueueDeclareOkBody) frame;
-                _messageCount = declareOk.getMessageCount();
-                _consumerCount = declareOk.getConsumerCount();
+                if (matches)
+                {
+                    QueueDeclareOkBody declareOk = (QueueDeclareOkBody) frame;
+                    _messageCount = declareOk.getMessageCount();
+                    _consumerCount = declareOk.getConsumerCount();
+                }
                 return matches;
             }