Middleware/redis-stream-springboot-starter
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

移除~近似裁剪选项，替换成高级API调用

Browse Source
This commit is contained in:
hzj
2026-06-25 13:59:45 +08:00
parent 74f68c9680
commit fd9074de9b
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/com/njcn/middle/stream/support/StreamTrimScheduler.java
View File

@@ -81,11 +81,11 @@ public class StreamTrimScheduler implements SmartLifecycle {
long maxlen = props.getTrim().getMaxlen(); long maxlen = props.getTrim().getMaxlen();
for (String stream : distinctStreams()) { for (String stream : distinctStreams()) {
try { try {
redis.execute((RedisCallback<Object>) connection -> connection.execute("XTRIM", redis.opsForStream().trim(stream,maxlen);
stream.getBytes(StandardCharsets.UTF_8), // redis.execute((RedisCallback<Object>) connection -> connection.execute("XTRIM",
"MAXLEN".getBytes(StandardCharsets.UTF_8), // stream.getBytes(StandardCharsets.UTF_8),
"~".getBytes(StandardCharsets.UTF_8), // "MAXLEN".getBytes(StandardCharsets.UTF_8),
String.valueOf(maxlen).getBytes(StandardCharsets.UTF_8))); // String.valueOf(maxlen).getBytes(StandardCharsets.UTF_8)));
} catch (Exception e) { } catch (Exception e) {
log.warn("[redis-stream] trim failed stream={}", stream, e); log.warn("[redis-stream] trim failed stream={}", stream, e);
} }