Method: MessageBus::Backends::Postgres#get_message

Defined in:

lib/message_bus/backends/postgres.rb

#get_message(channel, message_id) ⇒ MessageBus::Message^?

Get a specific message from a channel

Parameters:

• channel (String) —

  the name of the channel in question

• message_id (Integer) —

  the channel-specific ID of the message required

Returns:

• (MessageBus::Message, nil) —

  the requested message, or nil if it does not exist

# File 'lib/message_bus/backends/postgres.rb', line 317

def get_message(channel, message_id)
  if data = client.get_value(channel, message_id)
    MessageBus::Message.new message_id, message_id, channel, data
  else
    nil
  end
end