Class: Consumer::Postgres::Controls::Consumer::Incrementing::Handler
- Inherits:
-
Object
- Object
- Consumer::Postgres::Controls::Consumer::Incrementing::Handler
- Includes:
- Log::Dependency, Messaging::Handle
- Defined in:
- lib/consumer/postgres/controls/consumer.rb
Instance Method Summary collapse
Instance Method Details
#handle(message_data) ⇒ Object
16 17 18 19 |
# File 'lib/consumer/postgres/controls/consumer.rb', line 16 def handle() logger.info { "Handled message (StreamName: #{.stream_name}, GlobalPosition: #{.global_position})" } logger.debug { .data.pretty_inspect } end |