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: