class DispatchRider::Handlers::Base
Attributes
raw_message[R]
Public Class Methods
set_default_retry( amount )
click to toggle source
# File lib/dispatch-rider/handlers/base.rb, line 8 def set_default_retry( amount ) define_method(:retry_timeout) do amount end end
Public Instance Methods
do_process(raw_message)
click to toggle source
# File lib/dispatch-rider/handlers/base.rb, line 17 def do_process(raw_message) with_named_process(raw_message) do @raw_message = raw_message process(raw_message.body) end rescue Exception => e self.retry if self.retry_on_failure? raise e end
process(message)
click to toggle source
# File lib/dispatch-rider/handlers/base.rb, line 27 def process(message) raise NotImplementedError, "Method 'process' not overridden in subclass!" end
Protected Instance Methods
extend_timeout(timeout)
click to toggle source
# File lib/dispatch-rider/handlers/base.rb, line 33 def extend_timeout(timeout) raw_message.extend_timeout(timeout) end
retry()
click to toggle source
# File lib/dispatch-rider/handlers/base.rb, line 41 def retry timeout = retry_timeout case timeout when :immediate return_to_queue else extend_timeout(timeout) end end
retry_on_failure?()
click to toggle source
# File lib/dispatch-rider/handlers/base.rb, line 51 def retry_on_failure? self.respond_to? :retry_timeout end
return_to_queue()
click to toggle source
# File lib/dispatch-rider/handlers/base.rb, line 37 def return_to_queue raw_message.return_to_queue end