diff options
author | Rhenium <rhenium@rhe.jp> | 2013-07-29 17:05:33 +0900 |
---|---|---|
committer | Rhenium <rhenium@rhe.jp> | 2013-07-29 17:05:33 +0900 |
commit | d59bacfefbbdb177398e1631c955cbfcbd5397ec (patch) | |
tree | b4312cb8e5dd7c0d7b16b40208cdef47285e2707 /lib | |
parent | a170af32edc5f18bb4260fb81ef6c5ea885a5610 (diff) | |
download | aclog-d59bacfefbbdb177398e1631c955cbfcbd5397ec.tar.gz |
fix logging
Diffstat (limited to 'lib')
-rw-r--r-- | lib/aclog/receiver/collector_connection.rb | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/aclog/receiver/collector_connection.rb b/lib/aclog/receiver/collector_connection.rb index 8b566cc..245a680 100644 --- a/lib/aclog/receiver/collector_connection.rb +++ b/lib/aclog/receiver/collector_connection.rb @@ -134,7 +134,7 @@ module Aclog def receive_favorite(msg) @@queue.push -> do - Rails.logger.debug("Receive Favorite(#{@worker_number}): #{msg["user_id"]} => #{msg["tweet_id"]}") + Rails.logger.debug("Receive Favorite(#{@worker_number}): #{msg["user"]["id"]} => #{msg["tweet"]["id"]}") if f = Favorite.from_receiver(msg) f.tweet.notify_favorite end @@ -143,14 +143,14 @@ module Aclog def receive_unfavorite(msg) @@queue.push -> do - Rails.logger.debug("Receive Unfavorite(#{@worker_number}): #{msg["user_id"]} => #{msg["tweet_id"]}") + Rails.logger.debug("Receive Unfavorite(#{@worker_number}): #{msg["user"]["id"]} => #{msg["tweet"]["id"]}") Favorite.delete_from_receiver(msg) end end def receive_retweet(msg) @@queue.push -> do - Rails.logger.debug("Receive Retweet(#{@worker_number}): #{msg["user_id"]} => #{msg["tweet_id"]}") + Rails.logger.debug("Receive Retweet(#{@worker_number}): #{msg["user"]["id"]} => #{msg["tweet"]["id"]}") Retweet.from_receiver(msg) end end |