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.
This commit is contained in:
@@ -364,7 +364,7 @@ class DefaultStreamReceiver<K, V extends Record<K, ?>> implements StreamReceiver
|
||||
if (logger.isDebugEnabled()) {
|
||||
logger.debug(String.format("[stream: %s] onStreamMessage(%s): Buffering overflow", key, message));
|
||||
}
|
||||
overflow.add(message);
|
||||
overflow.offer(message);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user