aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRhenium <rhenium@rhe.jp>2013-07-29 17:05:33 +0900
committerRhenium <rhenium@rhe.jp>2013-07-29 17:05:33 +0900
commitd59bacfefbbdb177398e1631c955cbfcbd5397ec (patch)
treeb4312cb8e5dd7c0d7b16b40208cdef47285e2707
parenta170af32edc5f18bb4260fb81ef6c5ea885a5610 (diff)
downloadaclog-d59bacfefbbdb177398e1631c955cbfcbd5397ec.tar.gz
fix logging
-rw-r--r--lib/aclog/receiver/collector_connection.rb6
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