From daf48bb297c31f806a9eceaf9d171bbbd9f13fd1 Mon Sep 17 00:00:00 2001
From: James Strachan <jstrachan@apache.org>
Date: Tue, 14 Mar 2006 11:57:59 +0000
Subject: [PATCH] added better exception

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@385792 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/org/apache/activemq/ActiveMQConnection.java     | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
index 84df7a4d5b..4e52792f82 100755
--- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
+++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
@@ -143,8 +143,8 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
 
     private AdvisoryConsumer advisoryConsumer;
     private final CountDownLatch brokerInfoReceived = new CountDownLatch(1);
-
     private BrokerInfo brokerInfo;
+    private IOException firstFailureError;
 
 
 
@@ -1150,7 +1150,7 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
     protected synchronized void checkClosedOrFailed() throws JMSException {
         checkClosed();
         if (transportFailed.get()){
-            throw new ConnectionFailedException();
+            throw new ConnectionFailedException(firstFailureError);
         }
     }
     
@@ -1644,8 +1644,11 @@ public class ActiveMQConnection extends DefaultTransportListener implements Conn
         }
     }
     
-    protected void transportFailed(Throwable error){
+    protected void transportFailed(IOException error){
         transportFailed.set(true);
+        if (firstFailureError == null) {
+            firstFailureError = error;
+        }
         if (!closed.get() && !closing.get()) {
             try{
                 cleanup();