test/sample_ipc_server.rb in avro-1.3.0 vs test/sample_ipc_server.rb in avro-1.3.3
- old
+ new
@@ -79,13 +79,14 @@
class MailHandler < RequestHandler
def handle(request)
responder = MailResponder.new()
transport = Avro::IPC::SocketTransport.new(request)
- transport.write_framed_message(responder.respond(transport))
+ str = transport.read_framed_message
+ transport.write_framed_message(responder.respond(str))
end
end
if $0 == __FILE__
handler = MailHandler.new('localhost', 9090)
handler.run
-end
\ No newline at end of file
+end