Merge pull request #10271 from rabbitmq/fix-stream-topology-error-code

Return error atom according to specification
rabbitmq · Jan 4, 2024 · b4804a8 · b4804a8
2 parents 6554336 + 6a33056
commit b4804a8
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/deps/rabbitmq_stream/src/rabbit_stream_manager.erl b/deps/rabbitmq_stream/src/rabbit_stream_manager.erl
@@ -418,8 +418,10 @@ handle_call({topology, VirtualHost, Stream}, _From, State) ->
                                      #{leader_node => undefined,
                                        replica_nodes => []},
                                      Members)};
-                      _ ->
-                          {error, not_available}
+                      Err ->
+                          rabbit_log:info("Error locating ~tp stream members: ~tp",
+                                          [StreamName, Err]),
+                          {error, stream_not_available}
                   end;
               {error, not_found} ->
                   {error, stream_not_found};