From a194c11e33cc9a08ee5c62f476813cbd759f8354 Mon Sep 17 00:00:00 2001 From: David Turner Date: Thu, 22 Dec 2022 14:56:40 +0000 Subject: [PATCH] May as well finish up on the ccr threadpool too --- .../org/elasticsearch/xpack/ccr/rest/RestCcrStatsAction.java | 4 ++-- .../elasticsearch/xpack/ccr/rest/RestFollowStatsAction.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestCcrStatsAction.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestCcrStatsAction.java index 5ea23c7e16cb4..c3e93b418d86c 100644 --- a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestCcrStatsAction.java +++ b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestCcrStatsAction.java @@ -14,7 +14,7 @@ import org.elasticsearch.rest.BaseRestHandler; import org.elasticsearch.rest.RestRequest; import org.elasticsearch.rest.action.RestChunkedToXContentListener; -import org.elasticsearch.threadpool.ThreadPool; +import org.elasticsearch.xpack.ccr.Ccr; import org.elasticsearch.xpack.core.ccr.action.CcrStatsAction; import java.util.List; @@ -44,7 +44,7 @@ protected RestChannelConsumer prepareRequest(final RestRequest restRequest, fina new ThreadedActionListener<>( logger, client.threadPool(), - ThreadPool.Names.MANAGEMENT, + Ccr.CCR_THREAD_POOL_NAME, new RestChunkedToXContentListener<>(channel), false ) diff --git a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestFollowStatsAction.java b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestFollowStatsAction.java index d034a5ebbe328..61c93bf6ac42f 100644 --- a/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestFollowStatsAction.java +++ b/x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/rest/RestFollowStatsAction.java @@ -15,7 +15,7 @@ import org.elasticsearch.rest.BaseRestHandler; import org.elasticsearch.rest.RestRequest; import org.elasticsearch.rest.action.RestChunkedToXContentListener; -import org.elasticsearch.threadpool.ThreadPool; +import org.elasticsearch.xpack.ccr.Ccr; import org.elasticsearch.xpack.core.ccr.action.FollowStatsAction; import java.util.List; @@ -46,7 +46,7 @@ protected RestChannelConsumer prepareRequest(final RestRequest restRequest, fina new ThreadedActionListener<>( logger, client.threadPool(), - ThreadPool.Names.MANAGEMENT, + Ccr.CCR_THREAD_POOL_NAME, new RestChunkedToXContentListener<>(channel), false )