diff options
| -rw-r--r-- | plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs | 2 | ||||
| -rw-r--r-- | plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs | 4 |
2 files changed, 3 insertions, 3 deletions
diff --git a/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs b/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs index aef0255..c662baa 100644 --- a/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs +++ b/plugins/ObjectCacheServer/src/Cache/CacheListenerPubQueue.cs @@ -109,7 +109,7 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Cache ///<inheritdoc/> public void PublishEvent(ChangeEvent changeEvent) { - if (!_listenerQueue.TryEnque(changeEvent)) + if (!_listenerQueue.TryEnqueue(changeEvent)) { _logProvider.Warn("Cache listener event queue is overflowing"); } diff --git a/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs b/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs index 4b76a9b..363f5ed 100644 --- a/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs +++ b/plugins/ObjectCacheServer/src/Cache/PeerEventQueueManager.cs @@ -228,13 +228,13 @@ namespace VNLib.Data.Caching.ObjectCache.Server.Cache FullMode = BoundedChannelFullMode.DropOldest, }); - public void PublishChange(ChangeEvent change) => Queue.TryEnque(change); + public void PublishChange(ChangeEvent change) => Queue.TryEnqueue(change); public void PublishChanges(Span<ChangeEvent> changes) { for (int i = 0; i < changes.Length; i++) { - Queue.TryEnque(changes[i]); + Queue.TryEnqueue(changes[i]); } } |