From 76930f43d0aaabbed20357a62444a1ee169c93f0 Mon Sep 17 00:00:00 2001
From: Mark Cheverton <mark.cheverton@ecafe.org>
Date: Thu, 7 Nov 2013 16:36:24 +0000
Subject: [PATCH] Making twitter connection retry on Reconnect exception being
 thrown

---
 lib/qswarm/clients/twitter.rb | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/lib/qswarm/clients/twitter.rb b/lib/qswarm/clients/twitter.rb
index a901f79..ccea48f 100644
--- a/lib/qswarm/clients/twitter.rb
+++ b/lib/qswarm/clients/twitter.rb
@@ -56,6 +56,10 @@ def run
                   emit(:raw => status.attrs, :type => :track, :topic => topic, :matches => matches, :text => status.text)
                 end
               end
+#            end.on_limit do |skip_count|
+#              Qswarm.logger.error "[#{@agent.name.inspect} #{@name.inspect}] There were #{skip_count} tweets missed because of rate limiting."
+            end.on_error do |message|
+              Qswarm.logger.error "[#{@agent.name.inspect} #{@name.inspect}] #{message}"
             end
           end
 
@@ -68,15 +72,19 @@ def run
                   emit(:raw => status.attrs, :type => :follow, :group => group, :user_id => status.user.id, :text => status.text)
                 end
               end
+#            end.on_limit do |skip_count|
+#              Qswarm.logger.error "[#{@agent.name.inspect} #{@name.inspect}] There were #{skip_count} tweets missed because of rate limiting."
+            end.on_error do |message|
+              Qswarm.logger.error "[#{@agent.name.inspect} #{@name.inspect}] #{message}"
             end
           end
-        end
 
         rescue TweetStream::ReconnectError
           Qswarm.logger.info "[#{@agent.name.inspect} #{@name.inspect}] Hit max reconnects, restarting tweetstream in 60 seconds ..."
           EM.timer(60, run)
         end
       end
+    end
   end
 end