From 538341d434c150d2b41396c34b277f550ba9b5dc 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 eab382f1a..14277d755 100644 --- a/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java +++ b/src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java @@ -357,7 +357,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); } }