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