module MessageStore::Postgres::Get::Call

Public Instance Methods

call(position=nil, stream_name: nil) click to toggle source
# File lib/message_store/postgres/get.rb, line 55
def call(position=nil, stream_name: nil)
  position ||= self.class::Defaults.position

  stream_name ||= self.stream_name

  assure

  logger.trace(tag: :get) { "Getting message data (#{log_text(stream_name, position)})" }

  result = get_result(stream_name, position)

  message_data = convert(result)

  logger.info(tag: :get) { "Finished getting message data (Count: #{message_data.length}, #{log_text(stream_name, position)})" }
  logger.info(tags: [:data, :message_data]) { message_data.pretty_inspect }

  message_data
end