From 3688b3982fca852b34abfc4ef449c5ff9ada3010 Mon Sep 17 00:00:00 2001
From: Raphael <raphael@joindiaspora.com>
Date: Thu, 2 Dec 2010 15:23:26 -0800
Subject: [PATCH] message queue should follow redirects

---
 lib/message_handler.rb | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/lib/message_handler.rb b/lib/message_handler.rb
index 802981ce9..101de70b2 100644
--- a/lib/message_handler.rb
+++ b/lib/message_handler.rb
@@ -6,6 +6,7 @@ class MessageHandler
 
   NUM_TRIES = 3
   TIMEOUT = 10 #seconds
+  REDIRECTS = 3
 
   def initialize
     @queue = EM::Queue.new
@@ -32,13 +33,13 @@ class MessageHandler
     @queue.pop{ |query|
       case query.type
       when :post
-        http = EventMachine::HttpRequest.new(query.destination).post :timeout => TIMEOUT, :body =>{:xml => query.body}
+        http = EventMachine::HttpRequest.new(query.destination).post :timeout => TIMEOUT, :redirects => REDIRECTS, :body =>{:xml => query.body}
         http.callback { process; process}
       when :get
-        http = EventMachine::HttpRequest.new(query.destination).get :timeout => TIMEOUT
+        http = EventMachine::HttpRequest.new(query.destination).get :timeout => TIMEOUT, :redirects => REDIRECTS
         http.callback {process}
       when :hub_publish
-        http = EventMachine::PubSubHubbub.new(query.destination).publish query.body, :timeout => TIMEOUT
+        http = EventMachine::PubSubHubbub.new(query.destination).publish query.body, :timeout => TIMEOUT, :redirects => REDIRECTS
         http.callback {process}
       else
         raise "message is not a type I know!"