svn commit: r508384 - /incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java

[ritchiem]

Author: ritchiem
Date: Fri Feb 16 05:05:54 2007
New Revision: 508384

URL: http://svn.apache.org/viewvc?view=rev&rev=508384
Log:
QPID-373 Queue|Exchange}{Bind|Declare} should be synchronous to correctly 
receive/handle error

Updated AMQSession to be synchronous. With the build error fixed!!

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

Modified: 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?view=diff&rev=508384&r1=508383&r2=508384
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
 Fri Feb 16 05:05:54 2007
@@ -298,7 +298,7 @@
                     {
                         _connection.exceptionReceived(new 
AMQNoConsumersException("Error: " + reason, bouncedMessage));
                     }
-                    else if (errorCode == (AMQConstant.NO_ROUTE)
+                    else if (errorCode == AMQConstant.NO_ROUTE)
                     {
                         _connection.exceptionReceived(new 
AMQNoRouteException("Error: " + reason, bouncedMessage));
                     }