diff options
| author | kjnilsson <knilsson@pivotal.io> | 2020-07-17 10:20:16 +0100 |
|---|---|---|
| committer | kjnilsson <knilsson@pivotal.io> | 2020-09-07 09:42:11 +0100 |
| commit | bb968fd2fe7bd6a7fabdeb63abaf67a17814eb13 (patch) | |
| tree | e0e17cabbe0c37df9a53c45e0a8de25122cba36a | |
| parent | b4468c76c42f811c9f98ea25307ccb03d462de73 (diff) | |
| download | rabbitmq-server-git-bb968fd2fe7bd6a7fabdeb63abaf67a17814eb13.tar.gz | |
Better handle version check
when the rabbit_fifo:version/0 function is missing.
| -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 |