1 files changed, 10 insertions, 4 deletions
diff --git a/plugins/ObjectCacheServer/src/ObjectCacheSystemState.cs b/plugins/ObjectCacheServer/src/ObjectCacheSystemState.cs
index cd5bf1b..f8ce8a9 100644
--- a/plugins/ObjectCacheServer/src/ObjectCacheSystemState.cs
+++ b/plugins/ObjectCacheServer/src/ObjectCacheSystemState.cs
@@ -187,15 +187,21 @@ namespace VNLib.Data.Caching.ObjectCache.Server
 
             CacheListenerPubQueue queue = new(plugin, PeerEventQueue);
 
-            //Must register background worker to listen for changes
+            //Must register the queue background worker to listen for changes
             _ = plugin.ObserveWork(queue, 150);
 
+            BlobCacheListenerConfig conf = new()
+            {
+                Log = plugin.Log.CreateScope(CacheConstants.LogScopes.BlobCacheListener),
+                MemoryManager = new SharedHeapFBMMemoryManager(SharedCacheHeap),
+                EnableMessageChecksums = MemoryConfiguration.EnableChecksums,
+            };
+
             //Endpoint only allows for a single reader
             Listener = new(
                 plugin.LoadMemoryCacheSystem(config, manager, MemoryConfiguration),
-                queue,
-                plugin.Log.CreateScope(CacheConstants.LogScopes.BlobCacheListener),
-                new SharedHeapFBMMemoryManager(SharedCacheHeap)
+                conf,
+                queue
             );
 
             InternalStore = new CacheStore(Listener.Cache);