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; /** * Created by vincent on 2020/8/5 */ @RestController public class TestController { @RequestMapping("/test") public String test(){ Task task = new Task(); MessageQueue.offer(SlaveType.Crn, 1, task); return "ok"; } }