Method: MessageBus::Rack::Middleware.backlog_to_json

Defined in:
lib/message_bus/rack/middleware.rb

.backlog_to_json(backlog) ⇒ Object 



49
50
51
52
53
54
55
56
57
58
59
 
# File 'lib/message_bus/rack/middleware.rb', line 49

def self.backlog_to_json(backlog)
  m = backlog.map do |msg|
    {
      global_id: msg.global_id,
      message_id: msg.message_id,
      channel: msg.channel,
      data: msg.data
    }
  end.to_a
  JSON.dump(m)
end