Skip to content

Commit 400fafd

Browse files
committed
Add stream queue commands fallbacks
1 parent b0f9797 commit 400fafd

File tree

1 file changed

+29
-4
lines changed

1 file changed

+29
-4
lines changed

deps/rabbit/src/rabbit_stream_queue.erl

Lines changed: 29 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
-include("mc.hrl").
1212

1313
-behaviour(rabbit_queue_type).
14+
-behaviour(rabbit_queue_commands).
1415

1516
-export([is_enabled/0,
1617
is_compatible/3,
@@ -68,8 +69,14 @@
6869
queue_vm_stats_sups/0,
6970
queue_vm_ets/0]).
7071

71-
%% queues commands
72-
-export([shrink_all/1]).
72+
%% commands
73+
-export([add_member/5,
74+
list_with_local_promotable/0,
75+
delete_member/3,
76+
peek/2,
77+
status/1,
78+
reclaim_memory/1,
79+
shrink_all/1]).
7380

7481
-include_lib("rabbit_common/include/rabbit.hrl").
7582
-include("amqqueue.hrl").
@@ -1475,5 +1482,23 @@ queue_vm_ets() ->
14751482
{[],
14761483
[]}.
14771484

1478-
shrink_all(Node) ->
1479-
delete_all_replicas(Node).
1485+
add_member(_VHost, _Name, _Node, _Membership, _Timeout) ->
1486+
{error, not_quorum_queue}.
1487+
1488+
list_with_local_promotable() ->
1489+
{error, not_quorum_queue}.
1490+
1491+
delete_member(_VHost, _Name, _Node) ->
1492+
{error, not_quorum_queue}.
1493+
1494+
peek(_Pos, _QName) ->
1495+
{error, not_quorum_queue}.
1496+
1497+
status(_QName) ->
1498+
{error, not_quorum_queue}.
1499+
1500+
reclaim_memory(_QName) ->
1501+
{error, not_quorum_queue}.
1502+
1503+
shrink_all(_Node) ->
1504+
{error, not_quorum_queue}.

0 commit comments

Comments
 (0)