lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb in basquiat-1.3.4 vs lib/basquiat/adapters/rabbitmq/requeue_strategies/base_strategy.rb in basquiat-1.3.5
- old
+ new
@@ -28,9 +28,13 @@
def nack(message)
@session.channel.nack(message.delivery_tag, false)
end
+ def requeue(message)
+ @session.channel.nack(message.delivery_tag, false, true)
+ end
+
private
attr_reader :session
end
end