Contents

class ExampleQueuePoller < Pheme::QueuePoller
  def handle(message)
    case message.status
    when 'complete', 'rejected'
      ExampleMessageHandler.new(message: message).handle
    else
      raise ArgumentError, "Unknown message status: #{message.status}"
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
pheme-0.0.7	spec/support/example_queue_poller.rb
pheme-0.0.6	spec/support/example_queue_poller.rb
pheme-0.0.5	spec/support/example_queue_poller.rb
pheme-0.0.4	spec/support/example_queue_poller.rb
pheme-0.0.3	spec/support/example_queue_poller.rb
pheme-0.0.2	spec/support/example_queue_poller.rb
pheme-0.0.1	spec/support/example_queue_poller.rb