test helpers: use the correct rabbit_fifo version

Author: mkuratczyk

deps/rabbitmq_ct_helpers/src/queue_utils.erl

@@ -21,19 +21,27 @@
 -define(WFM_SLEEP, 256).
 -define(WFM_DEFAULT_NUMS, 30_000 div ?WFM_SLEEP). %% ~30s
 
+rabbit_fifo_module([Server|_], Q) ->
+    Overview = erpc:call(Server, ra, member_overview, [Q]),
+    {ok, #{effective_machine_version := MacVer}, _} = Overview,
+    rabbit_fifo:which_module(MacVer).
+
 wait_for_messages_ready(Servers, QName, Ready) ->
+    Mod = rabbit_fifo_module(Servers, QName),
     wait_for_messages(Servers, QName, Ready,
-                      fun rabbit_fifo:query_messages_ready/1,
+                      fun Mod:query_messages_ready/1,
                       ?WFM_DEFAULT_NUMS).
 
 wait_for_messages_pending_ack(Servers, QName, Ready) ->
+    Mod = rabbit_fifo_module(Servers, QName),
     wait_for_messages(Servers, QName, Ready,
-                      fun rabbit_fifo:query_messages_checked_out/1,
+                      fun Mod:query_messages_checked_out/1,
                       ?WFM_DEFAULT_NUMS).
 
 wait_for_messages_total(Servers, QName, Total) ->
+    Mod = rabbit_fifo_module(Servers, QName),
     wait_for_messages(Servers, QName, Total,
-                      fun rabbit_fifo:query_messages_total/1,
+                      fun Mod:query_messages_total/1,
                       ?WFM_DEFAULT_NUMS).
 
 wait_for_messages(Servers, QName, Total, Fun) ->