Skip to content

Commit 68d0793

Browse files
committed
call the correct function in the backing module
1 parent 636b15c commit 68d0793

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/rabbitmq_message_deduplication/rabbit_message_deduplication_queue.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -468,14 +468,14 @@ defmodule RabbitMQMessageDeduplication.Queue do
468468
dqstate(queue_state: qs) = state
469469
acks = Enum.map(acks, fn(dqack(tag: ack_tag)) -> ack_tag end)
470470

471-
passthrough do: info(delivered_publish, acks, acc, qs)
471+
passthrough do: zip_msgs_and_acks(delivered_publish, acks, acc, qs)
472472
end
473473

474474
@impl :rabbit_backing_queue
475475
def zip_msgs_and_acks(delivered_publish, acks, acc, state) do
476476
dqstate(queue_state: qs) = state
477477

478-
passthrough do: info(delivered_publish, acks, acc, qs)
478+
passthrough do: zip_msgs_and_acks(delivered_publish, acks, acc, qs)
479479
end
480480

481481
@impl :rabbit_backing_queue

0 commit comments

Comments
 (0)