class MessageDriver::Adapters::BunnyAdapter::Subscription::AutoAckHandler

Public Instance Methods

call(*message_args) click to toggle source
# File lib/message_driver/adapters/bunny_adapter.rb, line 218
def call(*message_args)
  message = sub_ctx.args_to_message(*message_args, destination)
  consumer.call(message)
  sub_ctx.ack_message(message)
rescue => e
  nack_message(e, message)
  error_handler.call(e, message) unless error_handler.nil?
end