Skip to content

Commit 41eba5e

Browse files
committed
Remove CQv1
Starting from this commit it is no longer possible to convert data from CQv1 to CQv2. All data is expected to use CQv2.
1 parent df7c475 commit 41eba5e

File tree

7 files changed

+126
-1874
lines changed

7 files changed

+126
-1874
lines changed

deps/rabbit/src/rabbit_classic_queue_index_v2.erl

Lines changed: 69 additions & 216 deletions
Large diffs are not rendered by default.

deps/rabbit/src/rabbit_classic_queue_store_v2.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -147,8 +147,8 @@ info(#qs{ write_buffer = WriteBuffer }) ->
147147

148148
%% @todo I think we can disable the old message store at the same
149149
%% place where we create MsgId. If many queues receive the
150-
%% message, then we create an MsgId. If not, we don't. But
151-
%% we can only do this after removing support for v1.
150+
%% message, then we create an MsgId. If not, we don't until
151+
%% strictly necessary (large messages).
152152
write(SeqId, Msg, Props, State0 = #qs{ write_buffer = WriteBuffer0,
153153
write_buffer_size = WriteBufferSize }) ->
154154
?DEBUG("~0p ~0p ~0p ~0p", [SeqId, Msg, Props, State0]),

deps/rabbit/src/rabbit_guid.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131

3232
-spec start_link() -> rabbit_types:ok_pid_or_error().
3333

34+
%% @todo Serial can be in persistent_term instead of process.
3435
start_link() ->
3536
gen_server:start_link({local, ?SERVER}, ?MODULE,
3637
[update_disk_serial()], []).

0 commit comments

Comments
 (0)