Skip to content

Commit fe806bc

Browse files
committed
issue #85: add set_queue_version queue callback
It was added on RMQ release 3.8.10. Signed-off-by: Matteo Cafasso <[email protected]>
1 parent 228f905 commit fe806bc

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

lib/rabbitmq_message_deduplication/rabbit_message_deduplication_queue.ex

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -449,6 +449,11 @@ defmodule RabbitMQMessageDeduplication.Queue do
449449
passthrough1(state, do: set_queue_mode(queue_mode, qs))
450450
end
451451

452+
@impl :rabbit_backing_queue
453+
def set_queue_version(queue_version, state = dqstate(queue_state: qs)) do
454+
passthrough1(state, do: set_queue_version(queue_version, qs))
455+
end
456+
452457
@impl :rabbit_backing_queue
453458
def zip_msgs_and_acks(delivered_publish, acks = [dqack() | _], acc, state) do
454459
dqstate(queue_state: qs) = state

0 commit comments

Comments
 (0)