class Consumer::Postgres::Controls::Handler
Public Instance Methods
handle(message_data)
click to toggle source
# 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