diff --git a/Source/MQTTnet/Internal/BlockingQueue.cs b/Source/MQTTnet/Internal/BlockingQueue.cs
index 546b6461..2812349a 100644
--- a/Source/MQTTnet/Internal/BlockingQueue.cs
+++ b/Source/MQTTnet/Internal/BlockingQueue.cs
@@ -77,11 +77,11 @@ namespace MQTTnet.Internal
             }
         }
 
-        public void RemoveFirstIfEqual(TItem item)
+        public void RemoveFirstIfEqual(TItem item, Func<TItem, TItem, bool> areEqual)
         {
             lock (_syncRoot)
             {
-                if (_items.Count > 0 && EqualityComparer<TItem>.Default.Equals(_items.First.Value, item))
+                if (_items.Count > 0 && areEqual(_items.First.Value, item))
                 {
                     _items.RemoveFirst();
                 }