From 1958aeb069966b6d443d93418e1e4b767b937f8f Mon Sep 17 00:00:00 2001
From: "Timothy A. Bish" <tabish@apache.org>
Date: Mon, 14 Jan 2013 15:57:05 +0000
Subject: [PATCH] https://issues.apache.org/jira/browse/AMQ-4248

Don't swallow the exception.

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1432963 13f79535-47bb-0310-9956-ffa450edef68
---
 .../java/org/apache/activemq/broker/TransportConnection.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
index 45538b4bdf..46d0346bda 100755
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/TransportConnection.java
@@ -896,7 +896,7 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
                 }
                 dispatch(command);
             }
-        } catch (Throwable e) {
+        } catch (IOException e) {
             if (messageDispatch != null) {
                 TransmitCallback sub = messageDispatch.getTransmitCallback();
                 broker.postProcessDispatch(messageDispatch);
@@ -904,6 +904,7 @@ public class TransportConnection implements Connection, Task, CommandVisitor {
                     sub.onFailure();
                 }
                 messageDispatch = null;
+                throw e;
             }
         } finally {
             if (messageDispatch != null) {