Merge pull request #512 from ripienaar/511

(#511) Reduce logging in network loops
choria-legacy · Jun 8, 2018 · 175c90f · 175c90f
2 parents a8ba628 + a420e5f
commit 175c90f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/lib/mcollective/connector/nats.rb b/lib/mcollective/connector/nats.rb
@@ -359,10 +359,10 @@ def receive
         msg = nil
 
         until msg
-          Log.debug("Waiting for a message from NATS")
-
           received = connection.receive
 
+          Thread.pass
+
           begin
             msg = JSON.parse(received)
           rescue

diff --git a/lib/mcollective/util/natswrapper.rb b/lib/mcollective/util/natswrapper.rb
@@ -210,8 +210,7 @@ def subscribe(source_name, options={})
           Log.debug("Subscribing to %s" % source_name)
 
           unless @subscriptions.include?(source_name)
-            @subscriptions[source_name] = @client.subscribe(source_name, options) do |msg, _, sub|
-              Log.debug("Received a message on %s" % [sub])
+            @subscriptions[source_name] = @client.subscribe(source_name, options) do |msg, _, _|
               @received_queue << msg
             end
           end