#

luxiaotao1123

2020-08-08 e42c649b6e14af84202c2df7e35c486ea0b5442c

 src/main/java/com/zy/core/channel/TestController.java

@@ -1,6 +1,7 @@
package com.zy.core.channel;

import com.zy.core.cache.MessageQueue;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.Task;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@@ -14,8 +15,7 @@
    @RequestMapping("/test")
    public String test(){
        Task task = new Task();
        task.setId(1);
        MessageQueue.CRN_QUE.offer(task);
        MessageQueue.offer(SlaveType.Crn, 1, task);
        return "ok";
    }