diff options
Diffstat (limited to 'lib/aclog/receiver/collector_connection.rb')
| -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 |