nocebo/diaspora
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

message queue should follow redirects

Browse source
This commit is contained in:
Raphael 2010-12-02 15:23:26 -08:00
parent 30698d674b
commit 3688b3982f
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lib/message_handler.rb
View file

@ -6,6 +6,7 @@ class MessageHandler
NUM_TRIES = 3 NUM_TRIES = 3
TIMEOUT = 10 #seconds TIMEOUT = 10 #seconds
REDIRECTS = 3
def initialize def initialize
@queue = EM::Queue.new @queue = EM::Queue.new
@ -32,13 +33,13 @@ class MessageHandler
@queue.pop{ |query| @queue.pop{ |query|
case query.type case query.type
when :post 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} http.callback { process; process}
when :get 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} http.callback {process}
when :hub_publish 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} http.callback {process}
else else
raise "message is not a type I know!" raise "message is not a type I know!"