1 files changed, 4 insertions, 2 deletions
diff --git a/plugins/ObjectCacheServer/src/CacheEventQueueManager.cs b/plugins/ObjectCacheServer/src/CacheEventQueueManager.cs
index 049069e..3827121 100644
--- a/plugins/ObjectCacheServer/src/CacheEventQueueManager.cs
+++ b/plugins/ObjectCacheServer/src/CacheEventQueueManager.cs
@@ -104,7 +104,7 @@ namespace VNLib.Data.Caching.ObjectCache.Server
             }
 
             //Return the node's queue
-            return nq.Queue;
+            return nq;
         }
 
         ///<inheritdoc/>
@@ -183,8 +183,10 @@ namespace VNLib.Data.Caching.ObjectCache.Server
         //Interval to purge stale subscribers
         Task IIntervalScheduleable.OnIntervalAsync(ILogProvider log, CancellationToken cancellationToken)
         {
-            //Purge
+            log.Debug("Purging stale peer event queues");
+
             PurgeStaleSubscribers();
+            
             return Task.CompletedTask;
         }