reconnect 15 min laster after receive max reconnect error

siuying · Oct 11, 2010 · d7f1d3c · d7f1d3c
1 parent 08c36da
commit d7f1d3c
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/lib/reflect/reflect.rb b/lib/reflect/reflect.rb
@@ -57,7 +57,15 @@ def listen
         end
 
         stream.on_max_reconnects do |timeout, retries|
-      	  @logger.error "max reconnects reached"
+      	  @logger.error "max reconnects reached: timeout: #{timeout}, retries: #{retries}"
+
+      	  # reconnect after 15 minutes
+      	  stream.stop
+      	  sleep(900)
+      	  stream = Twitter::JSONStream.connect(
+            :path    => "/1/statuses/filter.json?follow=#{@user_id}",
+            :auth    => @twitter_auth
+          )
         end
 
         trap('TERM') {