lib/deimos/backends/base.rb in deimos-ruby-1.16.3 vs lib/deimos/backends/base.rb in deimos-ruby-1.16.4

- old
+ new

@@ -3,12 +3,13 @@ module Deimos module Backends # Abstract class for all publish backends. class Base class << self - # @param producer_class [Class < Deimos::Producer] + # @param producer_class [Class<Deimos::Producer>] # @param messages [Array<Deimos::Message>] + # @return [void] def publish(producer_class:, messages:) Deimos.config.logger.info( message: 'Publishing messages', topic: producer_class.topic, payloads: messages.map do |message| @@ -19,11 +20,12 @@ end ) execute(producer_class: producer_class, messages: messages) end - # @param producer_class [Class < Deimos::Producer] + # @param producer_class [Class<Deimos::Producer>] # @param messages [Array<Deimos::Message>] + # @return [void] def execute(producer_class:, messages:) raise NotImplementedError end end end