Merge pull request #3241 from rabbitmq/stream-absent

Handle 'absent' return value
2021-07-28 23:13:51 +03:00 · 2021-07-28 23:13:51 +03:00 · 6ef0c513e8
parent d8a38ecb48 606429e90c
commit 6ef0c513e8
1 changed files with 3 additions and 1 deletions
--- a/deps/rabbit/src/rabbit_stream_queue.erl
+++ b/deps/rabbit/src/rabbit_stream_queue.erl
@ -129,7 +129,9 @@ create_stream(Q0, Node) ->
                     [rabbit_misc:rs(QName), node(), Error]}
            end;
        {existing, Q} ->
-            {existing, Q}
+            {existing, Q};
+        {absent, Q, Reason} ->
+            {absent, Q, Reason}
    end.

 -spec delete(amqqueue:amqqueue(), boolean(),