CallbackController.java 1.1 KB

12345678910111213141516171819202122232425262728
  1. package cn.com.ctop.callback.controller;
  2. import com.xxl.mq.client.message.XxlMqMessage;
  3. import com.xxl.mq.client.producer.XxlMqProducer;
  4. import org.jeecg.common.api.vo.Result;
  5. import org.springframework.stereotype.Controller;
  6. import org.springframework.web.bind.annotation.PathVariable;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.ResponseBody;
  9. import javax.servlet.http.HttpServletRequest;
  10. import javax.servlet.http.HttpServletResponse;
  11. @Controller
  12. @RequestMapping("/")
  13. public class CallbackController {
  14. @RequestMapping("/{group}/{topic}")
  15. @ResponseBody
  16. public Result<String> callbackMethod(HttpServletRequest request,
  17. HttpServletResponse response,
  18. @PathVariable(name = "group") String group,
  19. @PathVariable(name = "topic") String topic){
  20. Result<String> result = new Result<>();
  21. XxlMqProducer.produce(new XxlMqMessage(group+"_"+topic, request.getQueryString()));
  22. result.success("success");
  23. return result;
  24. }
  25. }