diff --git a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java index e7a382b..7b95446 100644 --- a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java +++ b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/configuration/Constants.java @@ -18,7 +18,7 @@ public interface Constants { ConcurrentHashMap>> QUEUE_MAP = new ConcurrentHashMap<>(10); String DEQUE_SAVE_FILENAME = "save_data_deque"; - String QUEUE_SAVE_FILENAME = "save_data_deque"; + String QUEUE_SAVE_FILENAME = "save_data_queue"; TimeUnit TIMEOUT_UNIT = TimeUnit.SECONDS; long POLL_TIMEOUT = 1; diff --git a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java index 7fe26f2..cb5cce1 100644 --- a/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java +++ b/service-queue/src/main/java/com/lanyuanxiaoyao/service/queue/service/AutoSaveService.java @@ -48,7 +48,7 @@ public class AutoSaveService { } private void save(Map> o, String name) throws IOException { - if (o == null) { + if (o == null || o.isEmpty()) { return; } Map> map = new HashMap<>(o.size());