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