Module: Deimos::Consume::MessageConsumption

Extended by:
ActiveSupport::Concern
Included in:
ActiveRecordConsume::MessageConsumption, Deimos::Consumer
Defined in:
lib/deimos/consume/message_consumption.rb

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

#consume_message(_message) ⇒ void

This method returns an undefined value.

Consume incoming messages.

Parameters:

  • _message (Karafka::Messages::Message)

Raises:



13
14
15
 
# File 'lib/deimos/consume/message_consumption.rb', line 13

def consume_message(_message)
  raise MissingImplementationError
end