module Circuitry

Public Instance Methods

handle_message_with_middleware(message, &block) click to toggle source

# File lib/with_events/aws/topic.rb, line 8
def handle_message_with_middleware(message, &block)
  middleware.invoke(message.topic.name, message.body) do
    handle_with_skip_delete(message, &block)
  end
end

handle_with_skip_delete(message, &block) click to toggle source

# File lib/with_events/aws/topic.rb, line 14
def handle_with_skip_delete(message, &block)
  catch :skip_delete do
    handle_message(message, &block)
    delete_message(message)
  end
end