diff --git a/common/services/ASC.ElasticSearch/Engine/Client.cs b/common/services/ASC.ElasticSearch/Engine/Client.cs index 12c373dc19..703a953476 100644 --- a/common/services/ASC.ElasticSearch/Engine/Client.cs +++ b/common/services/ASC.ElasticSearch/Engine/Client.cs @@ -97,16 +97,12 @@ namespace ASC.ElasticSearch }); } - client = new ElasticClient(settings); - try { - var result = client.Ping(new PingRequest()); - - var isValid = result.IsValid; - - if (result.IsValid) + if (Ping(new ElasticClient(settings))) { + client = new ElasticClient(settings); + client.Ingest.PutPipeline("attachments", p => p .Processors(pp => pp .Attachment(a => a.Field("document.data").TargetField("document.attachment")) @@ -117,9 +113,10 @@ namespace ASC.ElasticSearch catch (Exception e) { Log.Error(e); - client = null; } + + return client; } } @@ -127,11 +124,14 @@ namespace ASC.ElasticSearch public bool Ping() { - var instance = Instance; + return Ping(Instance); + } - if (instance == null) return false; + private bool Ping(ElasticClient elasticClient) + { + if (elasticClient == null) return false; - var result = instance.Ping(new PingRequest()); + var result = elasticClient.Ping(new PingRequest()); Log.DebugFormat("Ping {0}", result.DebugInformation);