Class: Deimos::Utils::MessageBankHandler

Inherits:
Consumer show all
Includes:
Phobos::Handler
Defined in:
lib/deimos/utils/inline_consumer.rb

Overview

Class to return the messages consumed.

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Consumer

#around_consume

Methods inherited from BaseConsumer

#decode_key, decoder, key_decoder

Class Method Details

.config_class=(klass) ⇒ Object

Parameters:



42
43
44
 
# File 'lib/deimos/utils/inline_consumer.rb', line 42

def self.config_class=(klass)
  self.config.merge!(klass.config)
end

.start(_kafka_client) ⇒ Object

:nodoc:



47
48
49
 
# File 'lib/deimos/utils/inline_consumer.rb', line 47

def self.start(_kafka_client)
  self.total_messages = []
end

Instance Method Details

#consume(payload, metadata) ⇒ Object

:nodoc:



52
53
54
55
56
57
58
 
# File 'lib/deimos/utils/inline_consumer.rb', line 52

def consume(payload, metadata)
  puts "Got #{payload}"
  self.class.total_messages << {
    key: metadata[:key],
    payload: payload
  }
end