Method: MessageBus::Message#encode

Defined in:
lib/message_bus/message.rb

#encode ⇒ Object

only tricky thing to encode is pipes in a channel name … do a straight replace



22
23
24
 
# File 'lib/message_bus/message.rb', line 22

def encode
  "#{global_id}|#{message_id}|#{channel.gsub("|", "$$123$$")}|#{data}"
end