diff --git a/src/DotPulsar/Internal/UnackedMessageTracker.cs b/src/DotPulsar/Internal/UnackedMessageTracker.cs index 2b5ef030f..48b4f9b08 100644 --- a/src/DotPulsar/Internal/UnackedMessageTracker.cs +++ b/src/DotPulsar/Internal/UnackedMessageTracker.cs @@ -81,10 +81,8 @@ private IEnumerable CheckUnackedMessages() while (_awaitingAcks.TryPeek(out AwaitingAck awaiting) && awaiting.Elapsed > _ackTimeout) { - // Can I safely use Dequeue now instead of TryDequeue? if (_awaitingAcks.TryDequeue(out awaiting)) { - //If the MessageId is not acknowledged if (!_acked.Contains(awaiting.MessageId)) result.Add(awaiting.MessageId); else