class Pwwka::ErrorHandlers::NackAndRequeueOnce

Public Instance Methods

handle_error(receiver,queue_name,payload,delivery_info,exception) click to toggle source
# File lib/pwwka/error_handlers/nack_and_requeue_once.rb, line 5
def handle_error(receiver,queue_name,payload,delivery_info,exception)
  if delivery_info.redelivered
    log("Error Processing Message",queue_name,payload,delivery_info,exception)
    receiver.nack(delivery_info.delivery_tag)
  else
    log("Retrying an Error Processing Message",queue_name,payload,delivery_info,exception)
    receiver.nack_requeue(delivery_info.delivery_tag)
  end
  keep_going
end