Method: Consumer::Postgres::PositionStore#get

Defined in:
lib/consumer/postgres/position_store.rb

#get ⇒ Object 



36
37
38
39
40
41
42
43
44
 
# File 'lib/consumer/postgres/position_store.rb', line 36

def get
  message_data = read.(stream_name)

  return nil if message_data.nil?

  message = Messaging::Message::Import.(message_data, Recorded)

  message.position
end