Class: Consumer::Postgres::Controls::Handler

Inherits:
Object
  • Object
show all
Includes:
Log::Dependency, Messaging::Handle
Defined in:
lib/consumer/postgres/controls/handler.rb

Instance Method Summary collapse

Instance Method Details

#handle(message_data) ⇒ Object 



8
9
10
11
 
# File 'lib/consumer/postgres/controls/handler.rb', line 8

def handle(message_data)
  logger.info "Handled message (StreamName: #{message_data.stream_name}, Correlation Stream Name: #{message_data.metadata[:correlation_stream_name]}, GlobalPosition: #{message_data.global_position})"
  logger.debug message_data.data.pretty_inspect
end