From af79e74b95ce6222b6ca36b4246e1f6ffd643d78 Mon Sep 17 00:00:00 2001 From: Walter Oggioni Date: Thu, 6 Feb 2025 23:09:22 +0800 Subject: [PATCH] fixed max message size for memcache backend --- .../net/woggioni/rbcs/server/memcache/client/MemcacheClient.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rbcs-server-memcache/src/main/kotlin/net/woggioni/rbcs/server/memcache/client/MemcacheClient.kt b/rbcs-server-memcache/src/main/kotlin/net/woggioni/rbcs/server/memcache/client/MemcacheClient.kt index d163388..fa8568d 100644 --- a/rbcs-server-memcache/src/main/kotlin/net/woggioni/rbcs/server/memcache/client/MemcacheClient.kt +++ b/rbcs-server-memcache/src/main/kotlin/net/woggioni/rbcs/server/memcache/client/MemcacheClient.kt @@ -76,7 +76,7 @@ class MemcacheClient(private val cfg: MemcacheCacheConfiguration) : AutoCloseabl override fun channelCreated(ch: Channel) { val pipeline: ChannelPipeline = ch.pipeline() pipeline.addLast(BinaryMemcacheClientCodec()) - pipeline.addLast(BinaryMemcacheObjectAggregator(Integer.MAX_VALUE)) + pipeline.addLast(BinaryMemcacheObjectAggregator(cfg.maxSize)) } } return FixedChannelPool(bootstrap, channelPoolHandler, server.maxConnections)