|
@@ -87,7 +87,7 @@ public final class RedisStreamHolder {
|
|
|
*/
|
|
|
private static RedisScript<String> getAddScript() {
|
|
|
if (ADD_SCRIPT == null) {
|
|
|
- synchronized (RedisContextHolder.class) {
|
|
|
+ synchronized (RedisStreamHolder.class) {
|
|
|
if (ADD_SCRIPT == null) {
|
|
|
int capacity = getProperties().getCapacity();
|
|
|
if (capacity > 0) {
|