zhangc
2025-04-11 b2e9d1f13a8a88e2963f504926234589fa2d2787
src/main/java/com/zy/core/cache/MessageQueue.java
@@ -93,8 +93,16 @@
            case Lift:
                return LIFT_EXCHANGE.get(id).poll();
            case Devp:
                ConcurrentLinkedQueue<Task> tasks = DEVP_EXCHANGE.get(id);
                if (tasks == null) {
                    return null;
                }
                return DEVP_EXCHANGE.get(id).poll();
            case Led:
                ConcurrentLinkedQueue<Task> task2 = LED_EXCHANGE.get(id);
                if (task2 == null) {
                    return null;
                }
                return LED_EXCHANGE.get(id).poll();
            default:
                return null;