From 3823da8f18d8c4f9affd2ceca08a2e66c5825c87 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Wed, 11 Nov 2020 09:56:06 +0100 Subject: [PATCH] =?UTF-8?q?DATAREDIS-1246=20-=20Use=20Queue.offer(?= =?UTF-8?q?=E2=80=A6)=20instead=20of=20Queue.add(=E2=80=A6)=20to=20buffer?= =?UTF-8?q?=20Stream=20subscription=20overflow.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Using now the method implemented by SpscArrayQueue instead of the not implemented one. --- .../data/redis/stream/DefaultStreamReceiver.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java b/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java index d127d59cc..7d2c17159 100644 --- a/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java +++ b/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java @@ -364,7 +364,7 @@ class DefaultStreamReceiver> implements StreamReceiver if (logger.isDebugEnabled()) { logger.debug(String.format("[stream: %s] onStreamMessage(%s): Buffering overflow", key, message)); } - overflow.add(message); + overflow.offer(message); } }