Class: PublishingPlatformMessageQueueConsumer::MessageConsumer

Inherits:

Object

Object
PublishingPlatformMessageQueueConsumer::MessageConsumer

show all

Defined in:: lib/publishing_platform_message_queue_consumer/message_consumer.rb

Instance Method Summary collapse

#initialize(processors:) ⇒ MessageConsumer constructor

A new instance of MessageConsumer.
#process(message) ⇒ Object

Constructor Details

#initialize(processors:) ⇒ `MessageConsumer`

Returns a new instance of MessageConsumer.



3
4
5

# File 'lib/publishing_platform_message_queue_consumer/message_consumer.rb', line 3

def initialize(processors:)
  @processors = processors
end

Instance Method Details

#process(message) ⇒ `Object`

# File 'lib/publishing_platform_message_queue_consumer/message_consumer.rb', line 7

def process(message)
  @processors.each do |processor|
    break unless processor.process(message)
  end
end