bixuan
/
iot-card-plus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: bixuan:120d592688fbab5137e0f70ed813b7d8ff1d646c
Branches Tags
bixuan:master
bixuan:bixuan
..
compare: bixuan:d8b10d161ed039cdb58c3a84bdff395265125a3f
Branches Tags
bixuan:master
bixuan:bixuan

No commits in common. "120d592688fbab5137e0f70ed813b7d8ff1d646c" and "d8b10d161ed039cdb58c3a84bdff395265125a3f" have entirely different histories.
120d592688 ... d8b10d161e

2 changed files with 0 additions and 52 deletions
Show Stats Expand all files Collapse all files

26
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Consumer.java
View File

@ -1,26 +0,0 @@
package cn.iocoder.yudao.framework.mq.rocketmq.core;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
/**
* -
*
* @author HuangLei
* @since 2025-06-18
*/
@Component
@Slf4j
@RequiredArgsConstructor
@RocketMQMessageListener(
topic = TopicNameConstants.PAY_REFUND_ORDER,
consumerGroup = GroupConstants.PAY_ORDER_REFUND_GROUP)
public class Consumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
log.info("【消费】- {}", message);
}
}

26
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rocketmq/core/Product.java
View File

@ -1,26 +0,0 @@
package cn.iocoder.yudao.framework.mq.rocketmq.core;
import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
import jakarta.annotation.PostConstruct;
import lombok.AllArgsConstructor;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.stereotype.Component;
/**
* @author HuangLei
* @since 2025-06-18
*/
@Component
@AllArgsConstructor
public class Product {
private final RocketMQTemplate rocketMQTemplate;
@PostConstruct
public void init(){
System.out.println("开始发送消息");
rocketMQTemplate.convertAndSend("pay-refund-order", JsonUtils.toJsonString("hello world"));
}
}