lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb in basquiat-1.2.0 vs lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb in basquiat-1.3.0.pre.1

@@ -18,16 +18,20 @@
 
         def run(_message)
           fail Basquiat::Errors::SubclassResponsibility
         end
 
-        def ack(delivery_tag)
-          @session.channel.ack(delivery_tag)
+        def ack(message)
+          @session.channel.ack(message.delivery_tag)
         end
 
-        def unack(delivery_tag)
-          @session.channel.nack(delivery_tag, false)
+        def nack(message)
+          @session.channel.nack(message.delivery_tag, false)
         end
+
+        private
+
+        attr_reader :session
       end
     end
   end
 end