@@ -34,7 +34,6 @@ public class ElasticsearchNode : IDisposable
3434
3535 private readonly bool _doNotSpawnIfAlreadyRunning ;
3636 private readonly bool _shieldEnabled ;
37- private readonly bool _skipPluginVerification ;
3837 private ObservableProcess _process ;
3938 private IDisposable _processListener ;
4039
@@ -104,13 +103,11 @@ public ElasticsearchNode(
104103 bool runningIntegrations ,
105104 bool doNotSpawnIfAlreadyRunning ,
106105 string name ,
107- bool shieldEnabled ,
108- bool skipPluginVerification
106+ bool shieldEnabled
109107 )
110108 {
111109 this . _doNotSpawnIfAlreadyRunning = doNotSpawnIfAlreadyRunning ;
112110 this . _shieldEnabled = shieldEnabled ;
113- this . _skipPluginVerification = skipPluginVerification ;
114111
115112 var prefix = name . ToLowerInvariant ( ) ;
116113 var suffix = Guid . NewGuid ( ) . ToString ( "N" ) . Substring ( 0 , 6 ) ;
@@ -215,9 +212,9 @@ public IObservable<ElasticsearchMessage> Start(string typeOfCluster, string[] ad
215212
216213 if ( handle . WaitOne ( this . HandleTimeout , true ) ) return observable ;
217214
218- this . Stop ( ) ;
215+ this . Stop ( ) ;
219216 throw new Exception ( $ "Could not start elasticsearch within { this . HandleTimeout } ") ;
220- }
217+ }
221218
222219#if DOTNETCORE
223220 private IObservable < ElasticsearchMessage > UseAlreadyRunningInstance ( Signal handle )
@@ -232,13 +229,11 @@ private IObservable<ElasticsearchMessage> UseAlreadyRunningInstance(ManualResetE
232229
233230 if ( ! alreadyUp . IsValid ) return null ;
234231
235- if ( ! _skipPluginVerification )
236- {
237- var checkPlugins = client . CatPlugins ( ) ;
238- var missingPlugins = SupportedPlugins . Keys . Except ( checkPlugins . Records . Select ( r => r . Component ) ) . ToList ( ) ;
239- if ( missingPlugins . Any ( ) )
240- throw new Exception ( $ "Already running elasticsearch missed the following plugin(s): { string . Join ( ", " , missingPlugins ) } .") ;
241- }
232+ var checkPlugins = client . CatPlugins ( ) ;
233+
234+ var missingPlugins = SupportedPlugins . Keys . Except ( checkPlugins . Records . Select ( r => r . Component ) ) . ToList ( ) ;
235+ if ( missingPlugins . Any ( ) )
236+ throw new Exception ( $ "Already running elasticsearch missed the following plugin(s): { string . Join ( ", " , missingPlugins ) } .") ;
242237
243238 this . Started = true ;
244239 this . Port = 9200 ;
@@ -283,6 +278,8 @@ private void ValidateLicense()
283278
284279 if ( license . License . Status == LicenseStatus . Invalid )
285280 throw new Exception ( $ "{ exceptionMessageStart } but the license is invalid!") ;
281+
282+
286283 }
287284
288285#if DOTNETCORE
0 commit comments