From 9570dff3801661436469e0d7fee27b893e22659e Mon Sep 17 00:00:00 2001 From: RogueException Date: Tue, 29 Dec 2015 21:06:13 -0400 Subject: [PATCH] Exposed MessageQueue.Count --- src/Discord.Net/MessageQueue.cs | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/src/Discord.Net/MessageQueue.cs b/src/Discord.Net/MessageQueue.cs index 78af2e7b3..14cddb6e7 100644 --- a/src/Discord.Net/MessageQueue.cs +++ b/src/Discord.Net/MessageQueue.cs @@ -33,6 +33,8 @@ namespace Discord.Net private readonly ConcurrentQueue _pending; private int _nextWarning; + public int Count { get; private set; } + internal MessageQueue(DiscordClient client, Logger logger) { _client = client; @@ -62,13 +64,13 @@ namespace Discord.Net { await Task.Delay(interval).ConfigureAwait(false); - int count = _pending.Count; - if (count >= _nextWarning) + Count = _pending.Count; + if (Count >= _nextWarning) { _nextWarning *= 2; - _logger.Warning($"Queue is backed up, currently at {count} messages."); + _logger.Warning($"Queue is backed up, currently at {Count} messages."); } - else if (count < WarningStart) //Reset once the problem is solved + else if (Count < WarningStart) //Reset once the problem is solved _nextWarning = WarningStart; while (_pending.TryDequeue(out queuedMessage))