Class: Liam::MessageProcessor

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/liam/message_processor.rb

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(message) ⇒ MessageProcessor

Returns a new instance of MessageProcessor.



10
11
12
 
# File 'lib/liam/message_processor.rb', line 10

def initialize(message)
  @message = message
end

Class Method Details

.process(message) ⇒ Object

Raises:



14
15
16
17
18
19
 
# File 'lib/liam/message_processor.rb', line 14

def self.process(message)
  raise UnexpectedMessageError, message unless message.is_a?(Aws::SQS::Types::Message)
  Liam.logger.info 'Processing...'

  new(message).send(:process)
end