Class: Karafka::Web::Pro::Commanding::Commands::Partitions::Pause

Inherits:
Base
  • Object
show all
Defined in:
lib/karafka/web/pro/commanding/commands/partitions/pause.rb

Overview

Delegates the pause request into the partition changes tracker and dispatches the acceptance message back to Kafka

Instance Attribute Summary

Attributes inherited from Base

#command

Instance Method Summary collapse

Methods inherited from Base

#initialize

Constructor Details

This class inherits a constructor from Karafka::Web::Pro::Commanding::Commands::Base

Instance Method Details

#call ⇒ Object

Delegates the pause request to async handling



19
20
21
22
23
 
# File 'lib/karafka/web/pro/commanding/commands/partitions/pause.rb', line 19

def call
  Handlers::Partitions::Tracker.instance << command

  acceptance(command.to_h)
end