You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2007/02/16 14:05:55 UTC

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

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