@@ -207,7 +207,8 @@ public static MockTransportService createNewService(
207207 .version (version )
208208 .build (),
209209 clusterSettings ,
210- createTaskManager (settings , threadPool , taskHeaders , Tracer .NOOP , nodeId )
210+ taskHeaders ,
211+ nodeId
211212 );
212213 }
213214
@@ -227,12 +228,13 @@ public static MockTransportService createMockTransportService(Transport transpor
227228 String nodeId = UUIDs .randomBase64UUID ();
228229 return new MockTransportService (
229230 Settings .EMPTY ,
230- new StubbableTransport ( transport ) ,
231+ transport ,
231232 threadPool ,
232233 TransportService .NOOP_TRANSPORT_INTERCEPTOR ,
233234 (boundAddress ) -> DiscoveryNodeUtils .builder (nodeId ).address (boundAddress .publishAddress ()).build (),
234235 null , // clusterSettings
235- createTaskManager (Settings .EMPTY , threadPool , Set .of (), Tracer .NOOP , nodeId )
236+ Set .of (),
237+ nodeId
236238 );
237239 }
238240
@@ -260,27 +262,7 @@ public MockTransportService(
260262 interceptor ,
261263 localNodeFactory ,
262264 clusterSettings ,
263- createTaskManager (settings , threadPool , taskHeaders , Tracer .NOOP , nodeId )
264- );
265- }
266-
267- public MockTransportService (
268- Settings settings ,
269- StubbableTransport transport ,
270- ThreadPool threadPool ,
271- TransportInterceptor interceptor ,
272- Function <BoundTransportAddress , DiscoveryNode > localNodeFactory ,
273- @ Nullable ClusterSettings clusterSettings ,
274- TaskManager taskManager
275- ) {
276- this (
277- settings ,
278- transport ,
279- threadPool ,
280- interceptor ,
281- localNodeFactory ,
282- clusterSettings ,
283- taskManager ,
265+ createTaskManager (settings , threadPool , taskHeaders , Tracer .NOOP , nodeId ),
284266 new ClusterSettingsLinkedProjectConfigService (settings , clusterSettings , DefaultProjectResolver .INSTANCE ),
285267 DefaultProjectResolver .INSTANCE
286268 );
0 commit comments