remove ping on transaction

kubemq-io · Apr 18, 2021 · 3051940 · 3051940
1 parent 11bc401
commit 3051940
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/KubeMQ.SDK.csharp/Queue/Queue.cs b/KubeMQ.SDK.csharp/Queue/Queue.cs
@@ -1,6 +1,5 @@
 using System;
 using System.Collections.Generic;
-using Google.Protobuf;
 using KubeMQ.Grpc;
 using KubeMQ.SDK.csharp.Basic;
 using KubeMQ.SDK.csharp.Queue.Stream;
@@ -84,7 +83,7 @@ public Queue (string queueName, string clientID, int? maxNumberOfMessagesQueueMe
             this._waitTimeSecondsQueueMessages = waitTimeSecondsQueueMessages?? _waitTimeSecondsQueueMessages;
             this.addAuthToken (authToken);
             _logger = Logger.InitLogger (logger, "Queue");
-            this.Ping ();
+            //this.Ping ();
         }
         /// <summary>
         /// Send single message
@@ -302,7 +301,6 @@ public PingResult Ping () {
             PingResult rec = GetKubeMQClient ().Ping (new Empty ());
             _logger.LogDebug ($"Queue KubeMQ address:{_kubemqAddress} ping result:{rec}");
             return rec;
-
         }
 
     }