Skip to content

Commit aaeaf52

Browse files
acogoluegnesmergify[bot]
authored andcommitted
Return error atom according to specification
In stream topology function call. This would trigger an exception in the frame creation when the stream was not available because the atom was unexpected. (cherry picked from commit 6a33056)
1 parent 3fbb810 commit aaeaf52

File tree

1 file changed

+4
-2
lines changed

1 file changed

+4
-2
lines changed

deps/rabbitmq_stream/src/rabbit_stream_manager.erl

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -404,8 +404,10 @@ handle_call({topology, VirtualHost, Stream}, _From, State) ->
404404
#{leader_node => undefined,
405405
replica_nodes => []},
406406
Members)};
407-
_ ->
408-
{error, not_available}
407+
Err ->
408+
rabbit_log:info("Error locating ~tp stream members: ~tp",
409+
[StreamName, Err]),
410+
{error, stream_not_available}
409411
end;
410412
{error, not_found} ->
411413
{error, stream_not_found};

0 commit comments

Comments
 (0)