diff options
| author | Rhenium <rhenium@rhe.jp> | 2013-12-20 22:49:49 +0900 |
|---|---|---|
| committer | Rhenium <rhenium@rhe.jp> | 2013-12-20 22:49:49 +0900 |
| commit | fe149b9c821b180b28fe1a141a96f75df9e1a122 (patch) | |
| tree | dda9fd366820dc93f359eba728ee45e11c4515d4 /lib | |
| parent | 32c7d9a145076560ad8e79cefaf5277ee3e18c34 (diff) | |
| download | aclog-fe149b9c821b180b28fe1a141a96f75df9e1a122.tar.gz | |
update workers
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/aclog/receiver/collector_connection.rb | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/aclog/receiver/collector_connection.rb b/lib/aclog/receiver/collector_connection.rb index 9f43f00..6ba7175 100644 --- a/lib/aclog/receiver/collector_connection.rb +++ b/lib/aclog/receiver/collector_connection.rb @@ -57,7 +57,7 @@ module Aclog case msg["type"] when "unauthorized" @channel << -> { - log(:warn, "unauthorized: #{msg["user_id"]}") + log(:warn, "unauthorized: ##{msg["id"]}/#{msg["user_id"]}") } when "tweet" @channel << -> { @@ -121,7 +121,7 @@ module Aclog worker_number = (Settings.collector.count.times.to_a - @connections.keys).sort.first if worker_number == nil log(:warn, "all connection alive") - send_object(type: "fatal", message: "all connection alive") + send_object(type: "error", message: "all connection alive") close_connection_after_writing return end |