From b26747b7561d34e77038ff99f0a50fcfce05c8c6 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期二, 16 五月 2023 11:15:24 +0800 Subject: [PATCH] realtimeWatch crn --- src/main/java/com/zy/core/cache/MessageQueue.java | 1 + 1 files changed, 1 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/zy/core/cache/MessageQueue.java b/src/main/java/com/zy/core/cache/MessageQueue.java index 3537280..6a751f2 100644 --- a/src/main/java/com/zy/core/cache/MessageQueue.java +++ b/src/main/java/com/zy/core/cache/MessageQueue.java @@ -127,6 +127,7 @@ public static void clear(SlaveType type, Integer id){ switch (type) { case Crn: + CRN_EXCHANGE.get(id).clear(); break; case Devp: -- Gitblit v1.9.1