Method: MessageBus::Implementation#last_message

Defined in:
lib/message_bus.rb

#last_message(channel) ⇒ Object 



280
281
282
283
284
285
286
287
 
# File 'lib/message_bus.rb', line 280

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