|
|
@ -2,8 +2,8 @@ package org.jeecg.modules.test.rocketmq.controller;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
import cn.hutool.core.util.RandomUtil;
|
|
|
|
import cn.hutool.core.util.RandomUtil;
|
|
|
|
import io.swagger.annotations.Api;
|
|
|
|
import io.swagger.v3.oas.annotations.Operation;
|
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
|
|
import io.swagger.v3.oas.annotations.tags.Tag;
|
|
|
|
import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient;
|
|
|
|
import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient;
|
|
|
|
import org.jeecg.common.api.vo.Result;
|
|
|
|
import org.jeecg.common.api.vo.Result;
|
|
|
|
import org.jeecg.common.base.BaseMap;
|
|
|
|
import org.jeecg.common.base.BaseMap;
|
|
|
@ -23,7 +23,7 @@ import javax.servlet.http.HttpServletRequest;
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@RestController
|
|
|
|
@RestController
|
|
|
|
@RequestMapping("/sys/test")
|
|
|
|
@RequestMapping("/sys/test")
|
|
|
|
@Api(tags = "【微服务】MQ单元测试")
|
|
|
|
@Tag(name = "【微服务】MQ单元测试")
|
|
|
|
public class JeecgMqTestController {
|
|
|
|
public class JeecgMqTestController {
|
|
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
@Autowired
|
|
|
@ -38,7 +38,7 @@ public class JeecgMqTestController {
|
|
|
|
* @return
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
*/
|
|
|
|
@GetMapping(value = "/rocketmq")
|
|
|
|
@GetMapping(value = "/rocketmq")
|
|
|
|
@ApiOperation(value = "测试rocketmq", notes = "测试rocketmq")
|
|
|
|
@Operation(description = "测试rocketmq")
|
|
|
|
public Result<?> rabbitMqClientTest(HttpServletRequest req) {
|
|
|
|
public Result<?> rabbitMqClientTest(HttpServletRequest req) {
|
|
|
|
//rabbitmq消息队列测试
|
|
|
|
//rabbitmq消息队列测试
|
|
|
|
BaseMap map = new BaseMap();
|
|
|
|
BaseMap map = new BaseMap();
|
|
|
@ -49,7 +49,7 @@ public class JeecgMqTestController {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
@GetMapping(value = "/rocketmq2")
|
|
|
|
@GetMapping(value = "/rocketmq2")
|
|
|
|
@ApiOperation(value = "rocketmq消息总线测试", notes = "rocketmq消息总线测试")
|
|
|
|
@Operation(description = "rocketmq消息总线测试")
|
|
|
|
public Result<?> rabbitmq2(HttpServletRequest req) {
|
|
|
|
public Result<?> rabbitmq2(HttpServletRequest req) {
|
|
|
|
|
|
|
|
|
|
|
|
//rabbitmq消息总线测试
|
|
|
|
//rabbitmq消息总线测试
|
|
|
|