|
@@ -27,7 +27,9 @@ import org.elasticsearch.tasks.Task;
|
|
|
import org.elasticsearch.test.ESTestCase;
|
|
|
import org.elasticsearch.threadpool.ThreadPool;
|
|
|
import org.elasticsearch.transport.RemoteClusterServerInfo;
|
|
|
+import org.elasticsearch.transport.TcpTransport;
|
|
|
import org.elasticsearch.transport.TransportService;
|
|
|
+import org.junit.BeforeClass;
|
|
|
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.HashSet;
|
|
@@ -46,6 +48,11 @@ import static org.mockito.Mockito.when;
|
|
|
|
|
|
public class RemoteClusterNodesActionTests extends ESTestCase {
|
|
|
|
|
|
+ @BeforeClass
|
|
|
+ public static void ensureFeatureFlag() {
|
|
|
+ assumeTrue("untrusted remote cluster feature flag must be enabled", TcpTransport.isUntrustedRemoteClusterEnabled());
|
|
|
+ }
|
|
|
+
|
|
|
public void testDoExecute() {
|
|
|
final ThreadPool threadPool = mock(ThreadPool.class);
|
|
|
final ThreadContext threadContext = new ThreadContext(Settings.EMPTY);
|