Module: Deimos::Consume::BatchConsumption

Extended by:
ActiveSupport::Concern
Includes:
Phobos::BatchHandler
Included in:
ActiveRecordConsume::BatchConsumption, Deimos::Consumer
Defined in:
lib/deimos/consume/batch_consumption.rb,
sig/defs.rbs

Overview

Helper methods used by batch consumers, i.e. those with "inline_batch" delivery. Payloads are decoded then consumers are invoked with arrays of messages to be handled at once

Instance Method Summary collapse

Instance Method Details

#around_consume_batch ⇒ void

This method returns an undefined value.

@param batch

@param metadata

Parameters:

  • batch (::Array[String])
  • metadata (::Hash[untyped, untyped]) 


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

def around_consume_batch: (::Array[String] batch, ::Hash[untyped, untyped] metadata) -> void

#consume_batch ⇒ void

This method returns an undefined value.

Consume a batch of incoming messages.

@param _payloads

@param _metadata

Parameters:

  • _payloads (::Array[Phobos::BatchMessage])
  • _metadata (::Hash[untyped, untyped]) 


1681
1682
1683
 
# File 'sig/defs.rbs', line 1681

def consume_batch
  raise MissingImplementationError
end