Module: MessagePack::RPC::MessageReceiver

Included in:
TCPTransport::BasicSocket, UDPTransport::BasicSocket, UNIXTransport::BasicSocket
Defined in:
lib/msgpack/rpc/transport/base.rb

Instance Method Summary collapse

Instance Method Details

#on_message(msg, *ctx) ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
34
 
# File 'lib/msgpack/rpc/transport/base.rb', line 23

def on_message(msg, *ctx)
	case msg[0]
	when REQUEST
		on_request(msg[1], msg[2], msg[3], *ctx)
	when RESPONSE
		on_response(msg[1], msg[2], msg[3], *ctx)
	when NOTIFY
		on_notify(msg[1], msg[2], *ctx)
	else
		raise RPCError.new("unknown message type #{msg[0]}")
	end
end