removed excess dumb. pubsub should work now
This commit is contained in:
parent
cc01345edd
commit
57e47e5a68
1 changed files with 2 additions and 3 deletions
|
|
@ -21,7 +21,6 @@ class MessageHandler
|
|||
end
|
||||
|
||||
def add_hub_notification(hub_url, feed_url)
|
||||
Rails.logger.info("in message handler")
|
||||
@queue.push(Message.new(:hub_publish, hub_url, :body => feed_url))
|
||||
end
|
||||
|
||||
|
|
@ -35,8 +34,8 @@ class MessageHandler
|
|||
http = EventMachine::HttpRequest.new(query.destination).get :timeout => TIMEOUT
|
||||
http.callback {process}
|
||||
when :hub_publish
|
||||
http = EventMachine::PubSubHubbub.new(query.destination).publish :timeout => TIMEOUT
|
||||
http.callback {Rails.logger.info("got into hub_publish"); process}
|
||||
http = EventMachine::PubSubHubbub.new(query.destination).publish query.body, :timeout => TIMEOUT
|
||||
http.callback {process}
|
||||
else
|
||||
raise "message is not a type I know!"
|
||||
end
|
||||
|
|
|
|||
Loading…
Reference in a new issue