wip

Author: ansd

deps/rabbit/src/rabbit_stream_queue.erl

@@ -1282,23 +1282,11 @@ entry_to_msg(Entry, Offset, #resource{kind = queue, name = QName}, Name, LocalPi
                    _ ->
                        <<>>
                end,
-    RKeys0 = case XHeaders of
-                 #{<<"x-cc">> := {list, CCs}} ->
-                     [CC || {utf8, CC} <- CCs];
-                 _ ->
-                     []
-             end,
-    RKeys1 = case XHeaders of
-                 #{<<"x-routing-key">> := {utf8, RK}} ->
-                     [RK | RKeys0];
-                 _ ->
-                     RKeys0
-             end,
-    RKeys = case RKeys1 of
-                [] ->
-                    [QName];
+    RKeys = case XHeaders of
+                #{<<"x-routing-key">> := {utf8, RK}} ->
+                    [RK];
                 _ ->
-                    RKeys1
+                    [QName]
             end,
     Mc1 = mc:set_annotation(?ANN_EXCHANGE, Exchange, Mc0),
     Mc2 = mc:set_annotation(?ANN_ROUTING_KEYS, RKeys, Mc1),