diff options
| -rw-r--r-- | lib/collector/node_connection.rb | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/lib/collector/node_connection.rb b/lib/collector/node_connection.rb index 4791df6..d12f567 100644 --- a/lib/collector/node_connection.rb +++ b/lib/collector/node_connection.rb @@ -6,6 +6,9 @@ module Collector @@_id = 0 def initialize(queue) + # comm_inactivity_timeout exceed -> heatbeat -> (when alive) -> continue + # -> (when not) -> unbind + self.comm_inactivity_timeout = 10 @unpacker = MessagePack::Unpacker.new(symbolize_keys: true) @connection_id = (@@_id += 1) @authenticated = false |