mirror of
https://github.com/Xiao-MoMi/Custom-Fishing.git
synced 2025-12-19 15:09:24 +00:00
Update RedisManager.java
This commit is contained in:
@@ -364,7 +364,7 @@ public class RedisManager extends AbstractStorage {
|
||||
public BlockingThreadTask() {
|
||||
Thread thread = new Thread(() -> {
|
||||
var map = new HashMap<String, StreamEntryID>();
|
||||
map.put(getStream(), StreamEntryID.LAST_ENTRY);
|
||||
map.put(getStream(), StreamEntryID.XREAD_NEW_ENTRY);
|
||||
while (!this.stopped) {
|
||||
try {
|
||||
var connection = getJedis();
|
||||
|
||||
Reference in New Issue
Block a user