diff options
| -rw-r--r-- | deps/rabbit/src/rabbit_channel.erl | 5 | ||||
| -rw-r--r-- | deps/rabbit/src/rabbit_stream_queue.erl | 2 |
2 files changed, 7 insertions, 0 deletions
diff --git a/deps/rabbit/src/rabbit_channel.erl b/deps/rabbit/src/rabbit_channel.erl index cf4b160fcb..3b26f2811e 100644 --- a/deps/rabbit/src/rabbit_channel.erl +++ b/deps/rabbit/src/rabbit_channel.erl @@ -2174,6 +2174,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, diff --git a/deps/rabbit/src/rabbit_stream_queue.erl b/deps/rabbit/src/rabbit_stream_queue.erl index 14e83d85d3..139e84a5d0 100644 --- a/deps/rabbit/src/rabbit_stream_queue.erl +++ b/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)]), |