You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2010/05/24 16:18:30 UTC
svn commit: r947650 -
/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/AMQConnectionFailureException.java
Author: robbie
Date: Mon May 24 14:18:30 2010
New Revision: 947650
URL: http://svn.apache.org/viewvc?rev=947650&view=rev
Log:
QPID-2611: AMQConnectionFailureException records AMQPConstant message if cause is AMQPException
Applied patch from Andrew Kennedy <an...@gmail.com>
Modified:
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/AMQConnectionFailureException.java
Modified: qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/AMQConnectionFailureException.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/AMQConnectionFailureException.java?rev=947650&r1=947649&r2=947650&view=diff
==============================================================================
--- qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/AMQConnectionFailureException.java (original)
+++ qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/AMQConnectionFailureException.java Mon May 24 14:18:30 2010
@@ -18,12 +18,9 @@
* under the License.
*
*/
-
package org.apache.qpid;
-import java.util.ArrayList;
import java.util.Collection;
-import java.util.Iterator;
import org.apache.qpid.protocol.AMQConstant;
@@ -43,7 +40,7 @@ public class AMQConnectionFailureExcepti
public AMQConnectionFailureException(String message, Throwable cause)
{
- super(null, message, cause);
+ super(cause instanceof AMQException ? ((AMQException) cause).getErrorCode() : null, message, cause);
}
public AMQConnectionFailureException(AMQConstant errorCode, String message, Throwable cause)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org