From 3d896cee27ee2f1023199b72ae5343be02a92374 Mon Sep 17 00:00:00 2001
From: md_li <md_li@trip.com>
Date: Mon, 15 Apr 2024 17:43:43 +0800
Subject: [PATCH] fix Cumulator ut error

---
 .../redis/proxy/integrate/AbstractProxyIntegrationTest.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/redis/redis-proxy/src/test/java/com/ctrip/xpipe/redis/proxy/integrate/AbstractProxyIntegrationTest.java b/redis/redis-proxy/src/test/java/com/ctrip/xpipe/redis/proxy/integrate/AbstractProxyIntegrationTest.java
index 4f9f0fcae..9c8d40581 100644
--- a/redis/redis-proxy/src/test/java/com/ctrip/xpipe/redis/proxy/integrate/AbstractProxyIntegrationTest.java
+++ b/redis/redis-proxy/src/test/java/com/ctrip/xpipe/redis/proxy/integrate/AbstractProxyIntegrationTest.java
@@ -205,7 +205,7 @@ public ReceiveHandler(AtomicReference<ByteBuf> buffer) {
         public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
             ByteBuf byteBuf = (ByteBuf) msg;
             byteBuf.retain();
-            cumulator.cumulate(ctx.channel().alloc(), cumulation, byteBuf);
+            cumulation = cumulator.cumulate(ctx.channel().alloc(), cumulation, byteBuf);
             buffer.set(cumulation);
             super.channelRead(ctx, msg);
         }