src/main/java/com/zy/core/cache/MessageQueue.java
@@ -1,5 +1,6 @@ package com.zy.core.cache; import com.zy.asrs.utils.CommandUtils; import com.zy.core.Slave; import com.zy.core.enums.SlaveType; import com.zy.core.model.Task; @@ -127,6 +128,7 @@ public static void clear(SlaveType type, Integer id){ switch (type) { case Crn: CRN_EXCHANGE.get(id).clear(); break; case Devp: