root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 8 Packages Projects Releases Wiki Activity

Fix variable match

This commit is contained in:
dcorbacho 2021-03-26 17:55:07 +01:00
parent 09e85d2e3d
commit e98b343095
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deps/rabbit/src/rabbit_stream_coordinator.erl vendored
View File

@ -185,7 +185,7 @@ members(StreamId) when is_list(StreamId) ->
case ra:local_query({?MODULE, node()}, MFA) of case ra:local_query({?MODULE, node()}, MFA) of
{ok, {_, {ok, _} = Result}, _} -> {ok, {_, {ok, _} = Result}, _} ->
Result; Result;
{ok, {_, {error, not_found} = Result}, _} -> {ok, {_, {error, not_found}}, _} ->
%% fall back to consistent query %% fall back to consistent query
case ra:consistent_query({?MODULE, node()}, MFA) of case ra:consistent_query({?MODULE, node()}, MFA) of
{ok, Result, _} -> {ok, Result, _} ->