class MessageDriver::Adapters::BunnyAdapter::Subscription::TransactionalAckHandler
Public Instance Methods
call(*message_args)
click to toggle source
# File lib/message_driver/adapters/bunny_adapter.rb, line 229 def call(*message_args) message = sub_ctx.args_to_message(*message_args, destination) adapter.broker.client.with_message_transaction do consumer.call(message) sub_ctx.ack_message(message) end rescue => e nack_message(e, message) error_handler.call(e, message) unless error_handler.nil? end