From 06d1d55323fb13f3b9b572ab42d1544251663f37 Mon Sep 17 00:00:00 2001
From: Rajith Muditha Attapattu <rajith@apache.org>
Date: Tue, 3 May 2011 14:04:46 +0000
Subject: QPID-3214 Committing the suggested fix by Gordon Sim. All though the
 currentException may change by the time we call
 connection.exceptionReceived() it's not really a big issue. Chance of getting
 two successive sessions exceptions is rare if not none at all.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1099060 13f79535-47bb-0310-9956-ffa450edef68
---
 .../client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

(limited to 'qpid/java/client/src')

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
index 90a4c36464..be8d39e4b5 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession_0_10.java
@@ -1029,11 +1029,9 @@ public class AMQSession_0_10 extends AMQSession<BasicMessageConsumer_0_10, Basic
                 code = ee.getErrorCode().getValue();
             }
             AMQException amqe = new AMQException(AMQConstant.getConstant(code), se.getMessage(), se.getCause());
-
-            _connection.exceptionReceived(amqe);
-
             _currentException = amqe;
         }
+        _connection.exceptionReceived(_currentException);
     }
 
     public AMQMessageDelegateFactory getMessageDelegateFactory()
-- 
cgit v1.2.1