module BBK
  module AMQP
    module RejectionPolicies
      class Reject

        attr_reader :logger

        def initialize(logger: BBK::Utils::Logger.default)
          @logger = logger
        end
      
        def call(message, error)
          logger.debug "Reject message #{message.headers[:type]}[#{message.headers[:message_id]}] delivery tag: #{message.delivery_info[:delivery_tag].to_i}. Error: #{error.inspect}"
          message.delivery_info[:channel].reject message.delivery_info[:delivery_tag], false
        end

      end
    end
  end
end