Class: Deimos::PublishBackend

Inherits:

Object

• Object
• Deimos::PublishBackend

Defined in:

lib/deimos/publish_backend.rb

Overview

Abstract class for all publish backends.

Direct Known Subclasses

Backends::Db, Backends::Kafka, Backends::KafkaAsync

Class Method Summary

• .execute(producer_class:, messages:) ⇒ Object
• .publish(producer_class:, messages:) ⇒ Object

Class Method Details

.execute(producer_class:, messages:) ⇒ Object

Parameters:

• producer_class (Class < Deimos::Producer]) —

  roducer_class [Class < Deimos::Producer]

• messages (Array<Deimos::Message>)

Raises:

• (NotImplementedError)

# File 'lib/deimos/publish_backend.rb', line 25

def execute(producer_class:, messages:)
  raise NotImplementedError
end

.publish(producer_class:, messages:) ⇒ Object

Parameters:

• producer_class (Class < Deimos::Producer]) —

  roducer_class [Class < Deimos::Producer]

• messages (Array<Deimos::Message>)

# File 'lib/deimos/publish_backend.rb', line 9

def publish(producer_class:, messages:)
  Deimos.config.logger.info(
    message: 'Publishing messages',
    topic: producer_class.topic,
    payloads: messages.map do |message|
      {
        payload: message.payload,
        key: message.key
      }
    end
  )
  execute(producer_class: producer_class, messages: messages)
end