Elasticsearch Rest Integration Test setup

ElasticsearchIntegTest.java

import org.elasticsearch.common.network.NetworkModule;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.plugins.Plugin;
import org.elasticsearch.test.ESIntegTestCase;
import org.elasticsearch.test.NodeConfigurationSource;
import org.elasticsearch.transport.Netty4Plugin;
import org.elasticsearch.transport.nio.NioTransportPlugin;
import org.junit.Before;

import java.nio.file.Path;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;

@ESIntegTestCase.ClusterScope(scope=ESIntegTestCase.Scope.TEST)
public abstract class ElasticsearchIntegTest extends ESIntegTestCase {

    static {
        System.setProperty("es.set.netty.runtime.available.processors", "false");
    }

    @Override
    @Before
    public void setUp() throws Exception {
        super.setUp();
    }

    @Override
    protected Collection<Class<? extends Plugin>> nodePlugins() {
        Collection<Class<? extends Plugin>> plugins = new ArrayList<>();
        plugins.add(Netty4Plugin.class);
        return Collections.unmodifiableCollection(plugins);
    }

    @Override
    protected NodeConfigurationSource getNodeConfigSource() {
        Settings.Builder networkSettings = Settings.builder();
        networkSettings.put(NetworkModule.TRANSPORT_TYPE_KEY, getTestTransportType());

        NodeConfigurationSource nodeConfigurationSource = new NodeConfigurationSource() {
            @Override
            public Settings nodeSettings(int nodeOrdinal) {
                return Settings.builder()
                        .put(NetworkModule.HTTP_ENABLED.getKey(), true)
                        .put(NetworkModule.HTTP_TYPE_SETTING.getKey(), "netty4")
                        .put(NetworkModule.TRANSPORT_TYPE_SETTING.getKey(), "netty4")
                        .put(ElasticsearchIntegTest.this.nodeSettings(nodeOrdinal)).build();
            }

            @Override
            public Path nodeConfigPath(int nodeOrdinal) {
                return ElasticsearchIntegTest.this.nodeConfigPath(nodeOrdinal);
            }

            @Override
            public Collection<Class<? extends Plugin>> nodePlugins() {
                return ElasticsearchIntegTest.this.nodePlugins();
            }

            @Override
            public Settings transportClientSettings() {
                return Settings.builder()
                        .put(ElasticsearchIntegTest.this.transportClientSettings())
                        .put(networkSettings.build())
                        .build();
            }

            @Override
            public Collection<Class<? extends Plugin>> transportClientPlugins() {
                Collection<Class<? extends Plugin>> plugins = new ArrayList<>();
                plugins.add(NioTransportPlugin.class);
                return Collections.unmodifiableCollection(plugins);
            }
        };
        return nodeConfigurationSource;
    }
}