Method: Pheme::QueuePoller#handle

Defined in:
lib/pheme/queue_poller.rb

#handle(message, metadata, message_attributes) ⇒ Object 



138
139
140
141
142
143
144
145
146
 
# File 'lib/pheme/queue_poller.rb', line 138

def handle(message, metadata, message_attributes)
  if @message_handler
    @message_handler.new(message: message, metadata: metadata, message_attributes: message_attributes).handle
  elsif @block_message_handler
    @block_message_handler.call(message, metadata, message_attributes)
  else
    raise NotImplementedError
  end
end