Sha256: cb23f955e39bc5adca2462cb83e29bb40985503590a019084e63346e19219286
Contents?: true
Size: 601 Bytes
Versions: 37
Compression:
Stored size: 601 Bytes
Contents
require_relative "base_error_handler"
module Pwwka
module ErrorHandlers
class NackAndRequeueOnce < BaseErrorHandler
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
end
end
end
Version data entries
37 entries across 37 versions & 1 rubygems