Merge pull request #79 from luos/fix-priority-queue-info-crash

Mirror crashes when policy is applied to queue with Unacknowledged messages

Author: noxdafox

lib/rabbitmq_message_deduplication/rabbit_message_deduplication_queue.ex

@@ -454,14 +454,14 @@ defmodule RabbitMQMessageDeduplication.Queue do
     dqstate(queue_state: qs) = state
     acks = Enum.map(acks, fn(dqack(tag: ack_tag)) -> ack_tag end)
 
-    passthrough do: info(delivered_publish, acks, acc, qs)
+    passthrough do: zip_msgs_and_acks(delivered_publish, acks, acc, qs)
   end
 
   @impl :rabbit_backing_queue
   def zip_msgs_and_acks(delivered_publish, acks, acc, state) do
     dqstate(queue_state: qs) = state
 
-    passthrough do: info(delivered_publish, acks, acc, qs)
+    passthrough do: zip_msgs_and_acks(delivered_publish, acks, acc, qs)
   end
 
   @impl :rabbit_backing_queue