class Deimos::Backends::Base
Abstract class for all publish backends.
Public Class Methods
execute(producer_class:, messages:)
click to toggle source
@param producer_class [Class < Deimos::Producer] @param messages [Array<Deimos::Message>]
# File lib/deimos/backends/base.rb, line 26 def execute(producer_class:, messages:) raise NotImplementedError end
publish(producer_class:, messages:)
click to toggle source
@param producer_class [Class < Deimos::Producer] @param messages [Array<Deimos::Message>]
# File lib/deimos/backends/base.rb, line 10 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