Original commit: elastic/x-pack-elasticsearch@6e4d902deb
This commit is contained in:
Boaz Leskes 2017-02-06 16:48:44 +01:00
parent 77c477f575
commit ccf3ac9c82
1 changed files with 3 additions and 2 deletions

View File

@ -15,6 +15,7 @@ import org.elasticsearch.cluster.NodeConnectionsService;
import org.elasticsearch.cluster.block.ClusterBlocks;
import org.elasticsearch.cluster.metadata.IndexNameExpressionResolver;
import org.elasticsearch.cluster.node.DiscoveryNode;
import org.elasticsearch.cluster.node.DiscoveryNodes;
import org.elasticsearch.cluster.service.ClusterService;
import org.elasticsearch.common.settings.ClusterSettings;
import org.elasticsearch.common.settings.Setting;
@ -99,12 +100,12 @@ public class TransportMonitoringBulkActionTests extends ESTestCase {
new ClusterSettings(Settings.EMPTY, clusterSettings), threadPool, () -> node);
clusterService.setNodeConnectionsService(new NodeConnectionsService(Settings.EMPTY, null, null) {
@Override
public void connectToNodes(Iterable<DiscoveryNode> discoveryNodes) {
public void connectToNodes(DiscoveryNodes discoveryNodes) {
// skip
}
@Override
public void disconnectFromNodesExcept(Iterable<DiscoveryNode> nodesToKeep) {
public void disconnectFromNodesExcept(DiscoveryNodes nodesToKeep) {
// skip
}
});