examples/worker.rb in grenache-ruby-http-0.1.3 vs examples/worker.rb in grenache-ruby-http-0.1.4
- old
+ new
@@ -9,12 +9,10 @@
Signal.trap("INT") { EventMachine.stop }
Signal.trap("TERM") { EventMachine.stop }
c = Grenache::Http.new
- c.listen('test', 5004) do |env|
- body = env['rack.input'].read
- req = Grenache::Message.parse(body)
- "hello #{req.payload}"
+ c.listen('test', 5004) do |msg|
+ "hello #{msg.payload}"
end
end