Skip to content

Commit 6a33056

Browse files
committed
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.
1 parent 5886383 commit 6a33056

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
@@ -418,8 +418,10 @@ handle_call({topology, VirtualHost, Stream}, _From, State) ->
418418
#{leader_node => undefined,
419419
replica_nodes => []},
420420
Members)};
421-
_ ->
422-
{error, not_available}
421+
Err ->
422+
rabbit_log:info("Error locating ~tp stream members: ~tp",
423+
[StreamName, Err]),
424+
{error, stream_not_available}
423425
end;
424426
{error, not_found} ->
425427
{error, stream_not_found};

0 commit comments

Comments
 (0)