From 553e8134ee03d5c7659f52f3b115c130c5413ec5 Mon Sep 17 00:00:00 2001
From: kimchy <kimchy@gmail.com>
Date: Tue, 20 Jul 2010 18:33:44 +0300
Subject: [PATCH] create a send transaction exception on the calling thread and
 fill its stack, so we know where its coming from

---
 .../org/elasticsearch/transport/RemoteTransportException.java  | 2 +-
 .../elasticsearch/transport/SendRequestTransportException.java | 1 +
 .../java/org/elasticsearch/transport/TransportService.java     | 3 ++-
 3 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/RemoteTransportException.java b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/RemoteTransportException.java
index dca381e69ef..4dc9c8c7d82 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/RemoteTransportException.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/RemoteTransportException.java
@@ -23,7 +23,7 @@ import org.elasticsearch.ElasticSearchWrapperException;
 import org.elasticsearch.common.transport.TransportAddress;
 
 /**
- * @author kimchy (Shay Banon)
+ * @author kimchy (shay.banon)
  */
 public class RemoteTransportException extends TransportException implements ElasticSearchWrapperException {
 
diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/SendRequestTransportException.java b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/SendRequestTransportException.java
index bbece5a7496..344aa941a5c 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/SendRequestTransportException.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/SendRequestTransportException.java
@@ -28,5 +28,6 @@ public class SendRequestTransportException extends RemoteTransportException {
 
     public SendRequestTransportException(DiscoveryNode node, String action, Throwable cause) {
         super(node == null ? null : node.name(), node == null ? null : node.address(), action, cause);
+        fillStack();
     }
 }
diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/TransportService.java b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/TransportService.java
index 72434fde42d..76dba0116fe 100644
--- a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/TransportService.java
+++ b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/TransportService.java
@@ -195,9 +195,10 @@ public class TransportService extends AbstractLifecycleComponent<TransportServic
             }
             // callback that an exception happened, but on a different thread since we don't
             // want handlers to worry about stack overflows
+            final SendRequestTransportException sendRequestException = new SendRequestTransportException(node, action, e);
             threadPool.execute(new Runnable() {
                 @Override public void run() {
-                    handler.handleException(new SendRequestTransportException(node, action, e));
+                    handler.handleException(sendRequestException);
                 }
             });
         }