diff options
| author | rhenium <rhenium@rhe.jp> | 2014-05-18 20:29:16 +0900 |
|---|---|---|
| committer | rhenium <rhenium@rhe.jp> | 2014-05-18 20:29:16 +0900 |
| commit | 79a3e267b11d718275f8404174ae1443ec3c8965 (patch) | |
| tree | 8a280afbee5902a223ed65809419fdb1c083d6e2 /lib | |
| parent | d2b3da45a3ceb6b9e997eb573fee8f3fdcb34f14 (diff) | |
| download | aclog-79a3e267b11d718275f8404174ae1443ec3c8965.tar.gz | |
collector: transaction is not needed to flush events
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/collector/event_queue.rb | 30 |
1 files changed, 14 insertions, 16 deletions
diff --git a/lib/collector/event_queue.rb b/lib/collector/event_queue.rb index f04a0c7..4274ea8 100644 --- a/lib/collector/event_queue.rb +++ b/lib/collector/event_queue.rb @@ -10,27 +10,25 @@ module Collector end def flush - ActiveRecord::Base.transaction do - queue_user = @queue_user; @queue_user = {} - User.create_or_update_bulk_from_json(queue_user.values) + queue_user = @queue_user; @queue_user = {} + User.create_or_update_bulk_from_json(queue_user.values) - queue_tweet = @queue_tweet; @queue_tweet = {} - Tweet.create_bulk_from_json(queue_tweet.values) + queue_tweet = @queue_tweet; @queue_tweet = {} + Tweet.create_bulk_from_json(queue_tweet.values) - queue_favorite = @queue_favorite; @queue_favorite = [] - Favorite.create_bulk_from_json(queue_favorite) + queue_favorite = @queue_favorite; @queue_favorite = [] + Favorite.create_bulk_from_json(queue_favorite) - queue_retweet = @queue_retweet; @queue_retweet = [] - Retweet.create_bulk_from_json(queue_retweet) + queue_retweet = @queue_retweet; @queue_retweet = [] + Retweet.create_bulk_from_json(queue_retweet) - queue_unfavorite = @queue_unfavorite; @queue_unfavorite = [] - Favorite.delete_bulk_from_json(queue_unfavorite) + queue_unfavorite = @queue_unfavorite; @queue_unfavorite = [] + Favorite.delete_bulk_from_json(queue_unfavorite) - queue_delete = @queue_delete; @queue_delete = [] - if queue_delete.size > 0 - Tweet.destroy_bulk_from_json(queue_delete) - Retweet.delete_bulk_from_json(queue_delete) - end + queue_delete = @queue_delete; @queue_delete = [] + if queue_delete.size > 0 + Tweet.destroy_bulk_from_json(queue_delete) + Retweet.delete_bulk_from_json(queue_delete) end end |