Skip to content

Commit 0a7c919

Browse files
committed
WIP Remove CQv1
1 parent 82e0fe0 commit 0a7c919

File tree

6 files changed

+95
-1788
lines changed

6 files changed

+95
-1788
lines changed

deps/rabbit/src/rabbit_classic_queue.erl

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -430,6 +430,7 @@ supports_stateful_delivery() -> true.
430430
deliver(Qs0, Msg0, Options) ->
431431
%% add guid to content here instead of in rabbit_basic:message/3,
432432
%% as classic queues are the only ones that need it
433+
%% @todo Only if multiple queues.
433434
Msg = mc:prepare(store, mc:set_annotation(id, rabbit_guid:gen(), Msg0)),
434435
Mandatory = maps:get(mandatory, Options, false),
435436
MsgSeqNo = maps:get(correlation, Options, undefined),

0 commit comments

Comments
 (0)