diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/local/LocalTransport.java b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/local/LocalTransport.java index 80adecc8693..afde7d05d92 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/local/LocalTransport.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/local/LocalTransport.java @@ -235,7 +235,7 @@ public class LocalTransport extends AbstractLifecycleComponent implem try { handler.handleResponse(streamable); } catch (Exception e) { - handleException(handler, new ResponseHandlerFailureTransportException("Failed to handler response", e)); + handleException(handler, new ResponseHandlerFailureTransportException("Failed to handle response", e)); } } }); @@ -244,7 +244,7 @@ public class LocalTransport extends AbstractLifecycleComponent implem //noinspection unchecked handler.handleResponse(streamable); } catch (Exception e) { - handleException(handler, new ResponseHandlerFailureTransportException("Failed to handler response", e)); + handleException(handler, new ResponseHandlerFailureTransportException("Failed to handle response", e)); } } } diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/MessageChannelHandler.java b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/MessageChannelHandler.java index 3c735a6e382..d1910bd8c6d 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/MessageChannelHandler.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/MessageChannelHandler.java @@ -112,7 +112,7 @@ public class MessageChannelHandler extends SimpleChannelUpstreamHandler { try { handler.handleResponse(streamable); } catch (Exception e) { - handleException(handler, new ResponseHandlerFailureTransportException("Failed to handler response", e)); + handleException(handler, new ResponseHandlerFailureTransportException("Failed to handle response", e)); } } }); @@ -121,7 +121,7 @@ public class MessageChannelHandler extends SimpleChannelUpstreamHandler { //noinspection unchecked handler.handleResponse(streamable); } catch (Exception e) { - handleException(handler, new ResponseHandlerFailureTransportException("Failed to handler response", e)); + handleException(handler, new ResponseHandlerFailureTransportException("Failed to handle response", e)); } } }