This commit is contained in:
Shay Banon 2014-04-28 11:07:54 +02:00
parent 6899e642b5
commit 6b2c1d0f62
2 changed files with 4 additions and 4 deletions

View File

@ -282,10 +282,10 @@ public class LocalTransport extends AbstractLifecycleComponent<Transport> implem
handleException(handler, new TransportSerializationException("Failed to deserialize response of type [" + response.getClass().getName() + "]", e));
return;
}
handleParsedRespone(response, handler);
handleParsedResponse(response, handler);
}
protected void handleParsedRespone(final TransportResponse response, final TransportResponseHandler handler) {
protected void handleParsedResponse(final TransportResponse response, final TransportResponseHandler handler) {
threadPool.executor(handler.executor()).execute(new Runnable() {
@SuppressWarnings({"unchecked"})
@Override

View File

@ -47,9 +47,9 @@ public class AssertingLocalTransport extends LocalTransport {
}
@Override
protected void handleParsedRespone(final TransportResponse response, final TransportResponseHandler handler) {
protected void handleParsedResponse(final TransportResponse response, final TransportResponseHandler handler) {
ElasticsearchAssertions.assertVersionSerializable(ElasticsearchTestCase.randomVersion(random), response);
super.handleParsedRespone(response, handler);
super.handleParsedResponse(response, handler);
}
@Override