Skip to content

Commit afb2ff2

Browse files
committed
DATAREDIS-1246 - Use Queue.offer(…) instead of Queue.add(…) to buffer Stream subscription overflow.
Using now the method implemented by SpscArrayQueue instead of the not implemented one.
1 parent 3a2bac8 commit afb2ff2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/org/springframework/data/redis/stream/DefaultStreamReceiver.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -357,7 +357,7 @@ private void onStreamMessage(V message) {
357357
if (logger.isDebugEnabled()) {
358358
logger.debug(String.format("[stream: %s] onStreamMessage(%s): Buffering overflow", key, message));
359359
}
360-
overflow.add(message);
360+
overflow.offer(message);
361361
}
362362
}
363363

0 commit comments

Comments
 (0)