update:delete rocketmq

austin-handler/src/main/java/com/java3y/austin/handler/receiver/rocket/RocketMqReceiver.java

@@ -1,36 +0,0 @@
-package com.java3y.austin.handler.receiver.rocket;
-
-import cn.hutool.core.util.StrUtil;
-import com.alibaba.fastjson.JSON;
-import com.java3y.austin.common.domain.TaskInfo;
-import com.java3y.austin.handler.receiver.service.ConsumeService;
-import com.java3y.austin.support.constans.MessageQueuePipeline;
-import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
-import org.apache.rocketmq.spring.annotation.SelectorType;
-import org.apache.rocketmq.spring.core.RocketMQListener;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.stereotype.Component;
-
-import javax.annotation.Resource;
-
-/**
- * @program: austin
- * @description:
- * @author: Giorno
- * @create: 2022-07-18
- **/
-@Component
-@RocketMQMessageListener(topic = "${austin.business.topic.name}",
-        consumerGroup = "${austin.rocketmq.consumer.group}",
-        selectorType = SelectorType.TAG, selectorExpression = "${austin.business.tagId.value}")
-@ConditionalOnProperty(name = "austin-mq-pipeline", havingValue = MessageQueuePipeline.ROCKET_MQ)
-public class RocketMqReceiver implements RocketMQListener<String> {
-    @Resource
-    private ConsumeService consumeService;
-
-    @Override
-    public void onMessage(String message) {
-        if (StrUtil.isBlank(message)) return;
-        consumeService.consume2Send(JSON.parseArray(message, TaskInfo.class));
-    }
-}

austin-support/src/main/java/com/java3y/austin/support/mq/rocket/RocketSendMqServiceImpl.java

@@ -1,50 +0,0 @@
-package com.java3y.austin.support.mq.rocket;
-
-import cn.hutool.core.util.StrUtil;
-import com.java3y.austin.support.constans.MessageQueuePipeline;
-import com.java3y.austin.support.mq.SendMqService;
-import lombok.extern.slf4j.Slf4j;
-import org.apache.rocketmq.spring.core.RocketMQTemplate;
-import org.apache.rocketmq.spring.support.RocketMQHeaders;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
-import org.springframework.messaging.support.MessageBuilder;
-import org.springframework.stereotype.Service;
-
-import javax.annotation.Resource;
-
-/**
- * @program: austin
- * @description:
- * @author: Giorno
- * @create: 2022-07-16
- **/
-@Slf4j
-@Service
-@ConditionalOnProperty(name = "austin-mq-pipeline", havingValue = MessageQueuePipeline.ROCKET_MQ)
-public class RocketSendMqServiceImpl implements SendMqService {
-    @Resource
-    private RocketMQTemplate rocketMQTemplate;
-    @Value("${austin.business.topic.name}")
-    private String sendMessageTopic;
-
-    @Override
-    public void send(String topic, String jsonValue, String tagId) {
-        if (StrUtil.isBlank(topic) || !sendMessageTopic.equals(topic)) {
-            log.error("RocketSendMqServiceImpl err:{}", topic);
-            return;
-        }
-        if (StrUtil.isBlank(tagId)) {
-            rocketMQTemplate.convertAndSend(topic, jsonValue);
-            return;
-        }
-        rocketMQTemplate.send(topic, MessageBuilder.withPayload(jsonValue)
-                        .setHeader(RocketMQHeaders.TAGS, tagId)
-                        .build());
-    }
-
-    @Override
-    public void send(String topic, String jsonValue) {
-        this.send(topic, jsonValue);
-    }
-}