From 9fadc862a359cfc9049260667d194535f01a8afd Mon Sep 17 00:00:00 2001 From: Giorno Date: Thu, 21 Jul 2022 13:53:56 +0800 Subject: [PATCH] update:delete rocketmq --- .../receiver/rocket/RocketMqReceiver.java | 36 ------------- .../mq/rocket/RocketSendMqServiceImpl.java | 50 ------------------- 2 files changed, 86 deletions(-) delete mode 100644 austin-handler/src/main/java/com/java3y/austin/handler/receiver/rocket/RocketMqReceiver.java delete mode 100644 austin-support/src/main/java/com/java3y/austin/support/mq/rocket/RocketSendMqServiceImpl.java diff --git a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/rocket/RocketMqReceiver.java b/austin-handler/src/main/java/com/java3y/austin/handler/receiver/rocket/RocketMqReceiver.java deleted file mode 100644 index c8d7625..0000000 --- a/austin-handler/src/main/java/com/java3y/austin/handler/receiver/rocket/RocketMqReceiver.java +++ /dev/null @@ -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 { - @Resource - private ConsumeService consumeService; - - @Override - public void onMessage(String message) { - if (StrUtil.isBlank(message)) return; - consumeService.consume2Send(JSON.parseArray(message, TaskInfo.class)); - } -} diff --git a/austin-support/src/main/java/com/java3y/austin/support/mq/rocket/RocketSendMqServiceImpl.java b/austin-support/src/main/java/com/java3y/austin/support/mq/rocket/RocketSendMqServiceImpl.java deleted file mode 100644 index c6709ad..0000000 --- a/austin-support/src/main/java/com/java3y/austin/support/mq/rocket/RocketSendMqServiceImpl.java +++ /dev/null @@ -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); - } -}