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