Module: Deimos::Consume::MessageConsumption

Extended by:
ActiveSupport::Concern
Includes:
Phobos::Handler
Included in:
ActiveRecordConsume::MessageConsumption, Deimos::Consumer
Defined in:
lib/deimos/consume/message_consumption.rb,
sig/defs.rbs

Overview

Methods used by message-by-message (non-batch) consumers. These consumers are invoked for every individual message.

Instance Method Summary collapse

Instance Method Details

#around_consume ⇒ void

This method returns an undefined value.

@param payload

@param metadata

Parameters:

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


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

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

#consume ⇒ void

This method returns an undefined value.

Consume incoming messages.

@param _payload

@param _metadata

Parameters:

  • _payload (String)
  • _metadata (::Hash[untyped, untyped]) 


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

def consume: (String _payload, ::Hash[untyped, untyped] _metadata) -> void

#consume_message(_message) ⇒ void

This method returns an undefined value.

Consume incoming messages.

Parameters:

  • _message (Karafka::Messages::Message)

Raises:



15
16
17
 
# File 'lib/deimos/consume/message_consumption.rb', line 15

def consume_message(_message)
  raise MissingImplementationError
end