on dynamic index creation when indexing, we might raise failure on routing (for example), but then not notify the listener

modules/elasticsearch/src/main/java/org/elasticsearch/action/index/TransportIndexAction.java

@@ -107,7 +107,11 @@ public class TransportIndexAction extends TransportShardReplicationOperationActi
                 @Override public void onFailure(Throwable e) {
                     if (ExceptionsHelper.unwrapCause(e) instanceof IndexAlreadyExistsException) {
                         // we have the index, do it
-                        innerExecute(request, listener);
+                        try {
+                            innerExecute(request, listener);
+                        } catch (Exception e1) {
+                            listener.onFailure(e1);
+                        }
                     } else {
                         listener.onFailure(e);
                     }