hhyykk/ipms-sjy
1
1
Fork 0
mirror of https://gitee.com/hhyykk/ipms-sjy.git synced 2025-07-23 23:45:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

[fix] 修改标签

Browse Source
This commit is contained in:
hhyykk
2024-10-09 14:42:26 +08:00
parent 550f4cbdae
commit 6eec60e9dd
116 changed files with 133 additions and 139 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/rabbitmq/config/YudaoRabbitMQAutoConfiguration.java
View File

@ -10,7 +10,7 @@ import org.springframework.context.annotation.Bean;
/**
* RabbitMQ 消息队列配置类
*
* @author 芋道源码
* @author hhyykk
*/
@AutoConfiguration
@Slf4j

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/config/YudaoRedisMQConsumerAutoConfiguration.java
View File

@ -33,7 +33,7 @@ import java.util.Properties;
/**
* Redis 消息队列 Consumer 配置类
*
* @author 芋道源码
* @author hhyykk
*/
@Slf4j
@EnableScheduling // 启用定时任务，用于 RedisPendingMessageResendJob 重发消息

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/config/YudaoRedisMQProducerAutoConfiguration.java
View File

@ -13,7 +13,7 @@ import java.util.List;
/**
* Redis 消息队列 Producer 配置类
*
* @author 芋道源码
* @author hhyykk
*/
@Slf4j
@AutoConfiguration(after = YudaoRedisAutoConfiguration.class)

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/core/RedisMQTemplate.java
View File

@ -17,7 +17,7 @@ import java.util.List;
/**
* Redis MQ 操作模板类
*
* @author 芋道源码
* @author hhyykk
*/
@AllArgsConstructor
public class RedisMQTemplate {

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/core/interceptor/RedisMessageInterceptor.java
View File

@ -7,7 +7,7 @@ import cn.iocoder.yudao.framework.mq.redis.core.message.AbstractRedisMessage;
* 通过拦截器，作为插件机制，实现拓展。
* 例如说，多租户场景下的 MQ 消息处理
*
* @author 芋道源码
* @author hhyykk
*/
public interface RedisMessageInterceptor {

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/core/message/AbstractRedisMessage.java
View File

@ -8,7 +8,7 @@ import java.util.Map;
/**
* Redis 消息抽象基类
*
* @author 芋道源码
* @author hhyykk
*/
@Data
public abstract class AbstractRedisMessage {

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/core/pubsub/AbstractRedisChannelMessage.java
View File

@ -6,7 +6,7 @@ import com.fasterxml.jackson.annotation.JsonIgnore;
/**
* Redis Channel Message 抽象类
*
* @author 芋道源码
* @author hhyykk
*/
public abstract class AbstractRedisChannelMessage extends AbstractRedisMessage {

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/core/pubsub/AbstractRedisChannelMessageListener.java
View File

@ -18,7 +18,7 @@ import java.util.List;
*
* @param <T> 消息类型。一定要填写噢，不然会报错
*
* @author 芋道源码
* @author hhyykk
*/
public abstract class AbstractRedisChannelMessageListener<T extends AbstractRedisChannelMessage> implements MessageListener {

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/core/stream/AbstractRedisStreamMessage.java
View File

@ -6,7 +6,7 @@ import com.fasterxml.jackson.annotation.JsonIgnore;
/**
* Redis Stream Message 抽象类
*
* @author 芋道源码
* @author hhyykk
*/
public abstract class AbstractRedisStreamMessage extends AbstractRedisMessage {

2
yudao-framework/yudao-spring-boot-starter-mq/src/main/java/cn/iocoder/yudao/framework/mq/redis/core/stream/AbstractRedisStreamMessageListener.java
View File

@ -20,7 +20,7 @@ import java.util.List;
*
* @param <T> 消息类型。一定要填写噢，不然会报错
*
* @author 芋道源码
* @author hhyykk
*/
public abstract class AbstractRedisStreamMessageListener<T extends AbstractRedisStreamMessage>
implements StreamListener<String, ObjectRecord<String, String>> {