From fe29b18c26c40ef33ea13d2696128224f2275a58 Mon Sep 17 00:00:00 2001 From: Yannick Welsch Date: Mon, 12 Nov 2018 11:05:11 +0100 Subject: [PATCH] Fix compilation --- .../elasticsearch/cluster/coordination/NodeJoinTests.java | 6 ------ .../test/disruption/DisruptableMockTransport.java | 7 ------- 2 files changed, 13 deletions(-) diff --git a/server/src/test/java/org/elasticsearch/cluster/coordination/NodeJoinTests.java b/server/src/test/java/org/elasticsearch/cluster/coordination/NodeJoinTests.java index 182e622d096..193ae721d92 100644 --- a/server/src/test/java/org/elasticsearch/cluster/coordination/NodeJoinTests.java +++ b/server/src/test/java/org/elasticsearch/cluster/coordination/NodeJoinTests.java @@ -46,7 +46,6 @@ import org.elasticsearch.transport.RequestHandlerRegistry; import org.elasticsearch.transport.TransportChannel; import org.elasticsearch.transport.TransportRequest; import org.elasticsearch.transport.TransportResponse; -import org.elasticsearch.transport.TransportResponseOptions; import org.elasticsearch.transport.TransportService; import org.junit.After; import org.junit.AfterClass; @@ -233,11 +232,6 @@ public class NodeJoinTests extends ESTestCase { future.markAsDone(); } - @Override - public void sendResponse(TransportResponse response, TransportResponseOptions options) { - sendResponse(response); - } - @Override public void sendResponse(Exception e) { logger.error(() -> new ParameterizedMessage("unexpected error for {}", future), e); diff --git a/test/framework/src/main/java/org/elasticsearch/test/disruption/DisruptableMockTransport.java b/test/framework/src/main/java/org/elasticsearch/test/disruption/DisruptableMockTransport.java index ae584901bf0..2743c11a2b6 100644 --- a/test/framework/src/main/java/org/elasticsearch/test/disruption/DisruptableMockTransport.java +++ b/test/framework/src/main/java/org/elasticsearch/test/disruption/DisruptableMockTransport.java @@ -29,7 +29,6 @@ import org.elasticsearch.transport.RequestHandlerRegistry; import org.elasticsearch.transport.TransportChannel; import org.elasticsearch.transport.TransportRequest; import org.elasticsearch.transport.TransportResponse; -import org.elasticsearch.transport.TransportResponseOptions; import java.io.IOException; import java.util.Optional; @@ -166,12 +165,6 @@ public abstract class DisruptableMockTransport extends MockTransport { }); } - @Override - public void sendResponse(TransportResponse response, - TransportResponseOptions options) { - sendResponse(response); - } - @Override public void sendResponse(Exception exception) { sendFromTo(destination, getLocalNode(), action, new Runnable() {