diff options
| -rw-r--r-- | src/rabbit_fifo_client.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_fifo_client.erl b/src/rabbit_fifo_client.erl index 8700b1e6af..dc98210817 100644 --- a/src/rabbit_fifo_client.erl +++ b/src/rabbit_fifo_client.erl @@ -145,7 +145,7 @@ enqueue(Correlation, Msg, cfg = #cfg{timeout = Timeout}} = State0) -> %% it is the first enqueue, check the version {_, Node} = Server = pick_server(State0), - case rpc:call(Node, rabbit_fifo, version, []) of + case rpc:call(Node, ra_machine, version, [{machine, rabbit_fifo, #{}}]) of 0 -> %% the leader is running the old version %% so we can't initialize the enqueuer session safely |