lib/dripdrop/handlers/http.rb in dripdrop-0.4.2 vs lib/dripdrop/handlers/http.rb in dripdrop-0.5.0
- old
+ new
@@ -88,22 +88,23 @@
@uri = uri
@address = @uri.to_s
@opts = opts
end
- def send_message(msg,&block)
- if msg.class == DripDrop::Message
+ def send_message(message,&block)
+ dd_message = dd_messagify(message)
+ if dd_message.class == DripDrop::Message
req = EM::Protocols::HttpClient.request(
:host => @uri.host, :port => @uri.port,
:request => '/', :verb => 'POST',
:contenttype => 'application/json',
- :content => msg.encode_json
+ :content => dd_message.encode_json
)
req.callback do |response|
block.call(DripDrop::Message.decode_json(response[:content]))
end
else
- raise "Unsupported message type '#{msg.class}'"
+ raise "Unsupported message type '#{dd_message.class}'"
end
end
end
end