peatio-core
peatio-core copied to clipboard
error in public message routing key
Hi! It looks like there is an error in stream key for public messages in Peatio::Ranger::Router.on_message in send_public_message(stream, message)
type, id, event = routing_key.split(".")
stream = [id, event].join(".")
send_public_message(stream, message)
I think there should be id, not stream