diff --git a/sofa-tracer-plugins/sofa-tracer-redis-plugin/src/main/java/com/sofa/alipay/tracer/plugins/spring/redis/connections/TracingRedisConnection.java b/sofa-tracer-plugins/sofa-tracer-redis-plugin/src/main/java/com/sofa/alipay/tracer/plugins/spring/redis/connections/TracingRedisConnection.java index 7ca0d2fd..77eeb049 100644 --- a/sofa-tracer-plugins/sofa-tracer-redis-plugin/src/main/java/com/sofa/alipay/tracer/plugins/spring/redis/connections/TracingRedisConnection.java +++ b/sofa-tracer-plugins/sofa-tracer-redis-plugin/src/main/java/com/sofa/alipay/tracer/plugins/spring/redis/connections/TracingRedisConnection.java @@ -202,7 +202,7 @@ public Boolean exists(byte[] key) { @Override public Long exists(byte[]... keys) { - return actionWrapper.doInScope(RedisCommand.EXISTS, keys, connection::exists); + return actionWrapper.doInScope(RedisCommand.EXISTS, keys, () -> connection.exists(keys)); } @Override @@ -212,7 +212,7 @@ public Long del(byte[]... keys) { @Override public Long unlink(byte[]... keys) { - return actionWrapper.doInScope(RedisCommand.UNLINK, keys, connection::unlink); + return actionWrapper.doInScope(RedisCommand.UNLINK, keys, () -> connection.unlink(keys)); } @Override @@ -222,7 +222,7 @@ public DataType type(byte[] key) { @Override public Long touch(byte[]... keys) { - return actionWrapper.doInScope(RedisCommand.TOUCH, keys, connection::touch); + return actionWrapper.doInScope(RedisCommand.TOUCH, keys, () -> connection.touch(keys)); } @Override