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



17
18
19

# File 'lib/message_bus/message.rb', line 17

def encode
  global_id.to_s << "|" << message_id.to_s << "|" << channel.gsub("|", "$$123$$") << "|" << data
end