Skip to content

Commit afb4032

Browse files
Ditto
1 parent 3290d23 commit afb4032

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

projects/client/RabbitMQ.Client/src/client/impl/RecoveryAwareModel.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ public override void BasicReject(ulong deliveryTag,
9797
var realTag = deliveryTag - activeDeliveryTagOffset;
9898
if(realTag > 0)
9999
{
100-
base.BasicReject(deliveryTag, requeue);
100+
base.BasicReject(realTag, requeue);
101101
}
102102
}
103103

@@ -107,7 +107,7 @@ public override void BasicNack(ulong deliveryTag,
107107
var realTag = deliveryTag - activeDeliveryTagOffset;
108108
if(realTag > 0)
109109
{
110-
base.BasicNack(deliveryTag, multiple, requeue);
110+
base.BasicNack(realTag, multiple, requeue);
111111
}
112112
}
113113

0 commit comments

Comments
 (0)