Skip to content

Commit a0aa6a6

Browse files
ikavgomichaelklishin
authored andcommitted
Add stream queue commands fallbacks
(cherry picked from commit dd2cccc) Conflicts: deps/rabbit/src/rabbit_stream_queue.erl
1 parent 366c643 commit a0aa6a6

File tree

1 file changed

+30
-2
lines changed

1 file changed

+30
-2
lines changed

deps/rabbit/src/rabbit_stream_queue.erl

Lines changed: 30 additions & 2 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,6 +69,15 @@
6869
queue_vm_stats_sups/0,
6970
queue_vm_ets/0]).
7071

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]).
80+
7181
-include_lib("rabbit_common/include/rabbit.hrl").
7282
-include("amqqueue.hrl").
7383
-include_lib("kernel/include/logger.hrl").
@@ -1525,5 +1535,23 @@ queue_vm_ets() ->
15251535
{[],
15261536
[]}.
15271537

1528-
read_ahead_on() ->
1529-
application:get_env(rabbit, stream_read_ahead, true).
1538+
add_member(_VHost, _Name, _Node, _Membership, _Timeout) ->
1539+
{error, not_quorum_queue}.
1540+
1541+
list_with_local_promotable() ->
1542+
{error, not_quorum_queue}.
1543+
1544+
delete_member(_VHost, _Name, _Node) ->
1545+
{error, not_quorum_queue}.
1546+
1547+
peek(_Pos, _QName) ->
1548+
{error, not_quorum_queue}.
1549+
1550+
status(_QName) ->
1551+
{error, not_quorum_queue}.
1552+
1553+
reclaim_memory(_QName) ->
1554+
{error, not_quorum_queue}.
1555+
1556+
shrink_all(_Node) ->
1557+
{error, not_quorum_queue}.

0 commit comments

Comments
 (0)