diff --git a/KubeMQ.SDK.csharp/Queue/Queue.cs b/KubeMQ.SDK.csharp/Queue/Queue.cs index 702a4f1..c6541b1 100644 --- 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 (); } /// /// 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; - } }