|
@@ -54,6 +54,7 @@ import org.elasticsearch.index.translog.TranslogConfig;
|
|
|
import org.elasticsearch.test.DummyShardLock;
|
|
|
import org.elasticsearch.test.ESTestCase;
|
|
|
import org.elasticsearch.test.IndexSettingsModule;
|
|
|
+import org.elasticsearch.threadpool.TestThreadPool;
|
|
|
import org.elasticsearch.threadpool.ThreadPool;
|
|
|
import org.junit.After;
|
|
|
import org.junit.Before;
|
|
@@ -93,7 +94,7 @@ public class RefreshListenersTests extends ESTestCase {
|
|
|
);
|
|
|
|
|
|
// Now setup the InternalEngine which is much more complicated because we aren't mocking anything
|
|
|
- threadPool = new ThreadPool(getTestName());
|
|
|
+ threadPool = new TestThreadPool(getTestName());
|
|
|
IndexSettings indexSettings = IndexSettingsModule.newIndexSettings("index", Settings.EMPTY);
|
|
|
ShardId shardId = new ShardId(new Index("index", "_na_"), 1);
|
|
|
Directory directory = newDirectory();
|