diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
index df4b2343e2..a86a2f7bee 100755
--- a/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadb/KahaDBTransactionStore.java
@@ -236,9 +236,9 @@ public class KahaDBTransactionStore implements TransactionStore {
                         try {
                             result.get();
                         } catch (InterruptedException e) {
-                            theStore.brokerService.handleIOException(new IOException(e));
+                            theStore.brokerService.handleIOException(new IOException(e.getMessage()));
                         } catch (ExecutionException e) {
-                            theStore.brokerService.handleIOException(new IOException(e));
+                            theStore.brokerService.handleIOException(new IOException(e.getMessage()));
                         }catch(CancellationException e) {
                         }
                         if (!result.isCancelled()) {