Method: MessageBus::Implementation#last_message

Defined in:
lib/message_bus.rb

#last_message(channel) ⇒ Object



307
308
309
310
311
312
313
314
# File 'lib/message_bus.rb', line 307

def last_message(channel)
  if last_id = last_id(channel)
    messages = backlog(channel, last_id - 1)
    if messages
      messages[0]
    end
  end
end