Class: Deimos::Utils::MessageBankHandler

Inherits:

Consumer

• Object
• Karafka::BaseConsumer
• Consumer
• Deimos::Utils::MessageBankHandler

Includes:

Phobos::Handler

Defined in:

sig/defs.rbs

Overview

Class to return the messages consumed.

Class Method Summary

• .config_class= ⇒ void

  @param klass.

• .start ⇒ void

  @param _kafka_client.

Instance Method Summary

• #consume ⇒ void

  @param payload.

Methods inherited from Consumer

#around_consume, #around_consume_batch, #consume_batch, #decode_key, #decode_message, decoder, key_decoder

Methods included from Consume::BatchConsumption

#around_consume_batch, #consume_batch

Methods included from Consume::MessageConsumption

#around_consume, #consume_message

Class Method Details

.config_class= ⇒ void

This method returns an undefined value.

@param klass

Parameters:

• klass (singleton(Deimos::Consumer))

# File 'sig/defs.rbs', line 1098

def self.config_class=: (singleton(Deimos::Consumer) klass) -> void

.start ⇒ void

This method returns an undefined value.

@param _kafka_client

Parameters:

• _kafka_client (Kafka::Client)

# File 'sig/defs.rbs', line 1101

def self.start: (Kafka::Client _kafka_client) -> void

Instance Method Details

#consume ⇒ void

This method returns an undefined value.

@param payload

@param metadata

Parameters:

• payload (::Hash[untyped, untyped])
• metadata (::Hash[untyped, untyped])

# File 'sig/defs.rbs', line 1106

def consume: (::Hash[untyped, untyped] payload, ::Hash[untyped, untyped] metadata) -> void