去除rocketmq

kxs-user/kxs-user-biz/src/main/java/com/kxs/user/biz/controller/kxsapp/TestMq.java

@@ -1,42 +0,0 @@
-package com.kxs.user.biz.controller.kxsapp;
-
-import com.kxs.common.core.util.R;
-import com.kxs.common.security.annotation.Inner;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.client.producer.SendResult;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.apache.rocketmq.spring.core.RocketMQTemplate;
-import org.springframework.messaging.Message;
-import org.springframework.messaging.support.MessageBuilder;
-import org.springframework.stereotype.Service;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-@Slf4j
-@RestController
-@RequiredArgsConstructor
-@RocketMQMessageListener(topic = "test-topic-1", consumerGroup = "test-group")
-public class TestMq implements RocketMQListener<String> {
-
-    private final RocketMQTemplate rocketMQTemplate;
-
-    public void onMessage(String message) {
-        log.info("received message: {}", message);
-    }
-
-
-    @Inner(value = false)
-    @GetMapping("/send/msg")
-    public R sendMsg1 (){
-        try {
-            Message<String> msg = MessageBuilder.withPayload("Hello,RocketMQ").build();
-            //发送信息
-            rocketMQTemplate.send("test-topic-1", msg);
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-        return R.ok();
-    }
-}