Merge pull request #3576 from rabbitmq/coordinator-error-handling

Handling of `stream_not_found` return value when init a stream client

Author: michaelklishin

deps/rabbit/src/rabbit_channel.erl

@@ -2176,6 +2176,11 @@ deliver_to_queues({Delivery = #delivery{message    = Message = #basic_message{ex
                     ok
             end,
             State;
+        {error, {stream_not_found, Resource}} ->
+            rabbit_misc:protocol_error(
+              resource_error,
+              "Stream not found for ~s",
+              [rabbit_misc:rs(Resource)]);
         {error, {coordinator_unavailable, Resource}} ->
             rabbit_misc:protocol_error(
               resource_error,

deps/rabbit/src/rabbit_stream_queue.erl

@@ -652,6 +652,8 @@ init(Q) when ?is_amqqueue(Q) ->
                                 leader = Leader,
                                 writer_id = WriterId,
                                 soft_limit = SoftLimit}};
+        {ok, stream_not_found, _} ->
+            {error, stream_not_found};
         {error, coordinator_unavailable} = E ->
             rabbit_log:warning("Failed to start stream client ~p: coordinator unavailable",
                                [rabbit_misc:rs(QName)]),