Skip to content

Commit 2116c0c

Browse files
committed
rabbit_stream_queue: Enable recovery after registering queue type
1 parent c81fbc5 commit 2116c0c

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

deps/rabbit/src/rabbit_stream_queue.erl

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,8 @@
126126
[queue, <<"stream">>, ?MODULE]}},
127127
{cleanup, {rabbit_registry, unregister,
128128
[queue, <<"stream">>]}},
129-
{requires, rabbit_registry}
129+
{requires, rabbit_registry},
130+
{enables, recovery}
130131
]}).
131132

132133
-type client() :: #stream_client{}.

0 commit comments

Comments
 (0)