lib/bbk/amqp/rejection_policies/republish.rb in bbk-amqp-1.1.0.204853 vs lib/bbk/amqp/rejection_policies/republish.rb in bbk-amqp-1.1.1.273342

@@ -10,10 +10,10 @@
         def initialize(publisher, logger: BBK::Utils::Logger.default)
           @publisher = publisher
           @logger = ActiveSupport::TaggedLogging.new(logger).tagged(self.class.name)
         end
 
-        def call(message, error)
+        def call(message, error, *_args, **_kwargs)
           if message.delivery_info[:redelivered] || message.headers.key?(REPUBLISH_COUNTER_KEY)
             republish_message(message, error)
           else
             requeue_message(message, error)
           end