Class: Kafkr::Consumer::Handler

Inherits:
Object
  • Object
show all
Defined in:
lib/kafkr/consumer.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.inherited(subclass) ⇒ Object 



65
66
67
 
# File 'lib/kafkr/consumer.rb', line 65

def self.inherited(subclass)
  Consumer.register_handler(subclass.new)
end

Instance Method Details

#handle(message) ⇒ Object

Raises:

  • (NotImplementedError) 


61
62
63
 
# File 'lib/kafkr/consumer.rb', line 61

def handle(message)
  raise NotImplementedError, "You must implement the handle method"
end

#handle?(message) ⇒ Boolean

Returns:

  • (Boolean)

Raises:

  • (NotImplementedError) 


57
58
59
 
# File 'lib/kafkr/consumer.rb', line 57

def handle?(message)
  raise NotImplementedError, "You must implement the handle? method"
end