Remove type (#22)

* changing from _type Trace to _type _doc to make compatible with ES 6.x * const for _type, change from _doc to doc
amccool · Mar 22, 2018 · fc9222d · fc9222d
1 parent 7f62aa8
commit fc9222d
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/ElasticSearch.Diagnostics/ElasticSearchTraceListener.cs b/ElasticSearch.Diagnostics/ElasticSearchTraceListener.cs
@@ -24,6 +24,8 @@ namespace ElasticSearch.Diagnostics
     /// </summary>
     public class ElasticSearchTraceListener : TraceListenerBase
     {
+        private const string DocumentType = "doc";
+
         private readonly BlockingCollection<JObject> _queueToBePosted = new BlockingCollection<JObject>();
 
         private IElasticLowLevelClient _client;
@@ -376,7 +378,7 @@ private async Task WriteDirectlyToES(JObject jo)
         {
 	        try
 	        {
-                await Client.IndexAsync<VoidResponse>(Index, "_doc", jo.ToString());
+                await Client.IndexAsync<VoidResponse>(Index, DocumentType, jo.ToString());
 	        }
 	        catch (Exception ex)
 	        {
@@ -389,15 +391,15 @@ private async Task WriteDirectlyToESAsBatch(IEnumerable<JObject> jos)
             if (!jos.Any())
                 return;
 
-            var indx = new { index = new { _index = Index, _type = "_doc" } };
+            var indx = new { index = new { _index = Index, _type = DocumentType } };
             var indxC = Enumerable.Repeat(indx, jos.Count());
 
             var bb = jos.Zip(indxC, (f, s) => new object[] { s, f });
             var bbo = bb.SelectMany(a => a);
 
             try
             {
-	            await Client.BulkPutAsync<VoidResponse>(Index, "_doc", bbo.ToArray(), br => br.Refresh(false));
+	            await Client.BulkPutAsync<VoidResponse>(Index, DocumentType, bbo.ToArray(), br => br.Refresh(false));
             }
             catch (Exception ex)
             {