Skip to content

Commit cd070ee

Browse files
committed
Rename x-redelivery-count to x-delivery-count to align with AMQP1.0
[#161057187]
1 parent 9cd1e0d commit cd070ee

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

src/rabbit_channel.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2492,4 +2492,4 @@ maybe_monitor_all(Items, S) -> lists:foldl(fun maybe_monitor/2, S, Items).
24922492

24932493
add_delivery_count_header(MsgHeader, Msg) ->
24942494
Count = maps:get(delivery_count, MsgHeader, 0),
2495-
rabbit_basic:add_header(<<"x-redelivery-count">>, long, Count, Msg).
2495+
rabbit_basic:add_header(<<"x-delivery-count">>, long, Count, Msg).

src/rabbit_quorum_queue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -333,7 +333,7 @@ basic_get(#amqqueue{name = QName, pid = {Name, _} = Id, type = quorum}, NoAck,
333333
{ok, {MsgId, {MsgHeader, Msg0}}, QState} ->
334334
Count = maps:get(delivery_count, MsgHeader, 0),
335335
IsDelivered = Count > 0,
336-
Msg = rabbit_basic:add_header(<<"x-redelivery-count">>, long, Count, Msg0),
336+
Msg = rabbit_basic:add_header(<<"x-delivery-count">>, long, Count, Msg0),
337337
{ok, quorum_messages(Name), {QName, Id, MsgId, IsDelivered, Msg}, QState};
338338
{timeout, _} ->
339339
{error, timeout}

test/quorum_queue_SUITE.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1650,7 +1650,7 @@ subscribe_redelivery_count(Config) ->
16501650
wait_for_messages_pending_ack(Servers, RaName, 0),
16511651
subscribe(Ch, QQ, false),
16521652

1653-
DTag = <<"x-redelivery-count">>,
1653+
DTag = <<"x-delivery-count">>,
16541654
receive
16551655
{#'basic.deliver'{delivery_tag = DeliveryTag,
16561656
redelivered = false},
@@ -1695,7 +1695,7 @@ consume_redelivery_count(Config) ->
16951695
wait_for_messages_ready(Servers, RaName, 1),
16961696
wait_for_messages_pending_ack(Servers, RaName, 0),
16971697

1698-
DTag = <<"x-redelivery-count">>,
1698+
DTag = <<"x-delivery-count">>,
16991699

17001700
{#'basic.get_ok'{delivery_tag = DeliveryTag,
17011701
redelivered = false},

0 commit comments

Comments
 (0)