collector/worker_node: use appname of Logger

2 files changed, 3 insertions, 3 deletions

diff --git a/lib/collector/node_connection.rb b/lib/collector/node_connection.rb
index f3da06f..3bf4b10 100644
--- a/lib/collector/node_connection.rb
+++ b/lib/collector/node_connection.rb
@@ -115,7 +115,7 @@ module Collector
     end
 
     def log(level, message)
-      Rails.logger.__send__(level, "[Node:#{@connection_id}] #{message}")
+      Rails.logger.__send__(level, "Node(#{@connection_id})") { message }
     end
   end
 end
diff --git a/lib/collector/node_manager.rb b/lib/collector/node_manager.rb
index e008dfa..4c308af 100644
--- a/lib/collector/node_manager.rb
+++ b/lib/collector/node_manager.rb
@@ -46,12 +46,12 @@ module Collector
           if con
             self.active_connections[first_inactive_id] = con
             con.activated_time = Time.now
-            Rails.logger.warn("[NodeManager] Registered node ##{con.connection_id} as group ##{first_inactive_id}")
+            Rails.logger.warn("NodeManager") { "Registered node ##{con.connection_id} as group ##{first_inactive_id}" }
             Account.for_node(first_inactive_id).each do |a|
               con.register_account(a)
             end
           else
-            Rails.logger.warn("[NodeManager] Not enough nodes: (#{self.active_connections.count {|c| c }}/#{Settings.collector.nodes_count})")
+            Rails.logger.warn("NodeManager") { "Not enough nodes: (#{self.active_connections.count {|c| c }}/#{Settings.collector.nodes_count})" }
           end
         end
       end