Skip to content

Commit

Permalink
cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
dionjansen committed Jan 3, 2021
1 parent f4725f5 commit 51f4a98
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions src/DotPulsar/Internal/UnackedMessageTracker.cs
Original file line number Diff line number Diff line change
Expand Up @@ -81,10 +81,8 @@ private IEnumerable<MessageId> 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
Expand Down

0 comments on commit 51f4a98

Please sign in to comment.