feat(mq): 添加 RocketMQ相关的常量接口

- 新增 GroupConstants 接口,定义了多个消费者组常量- 新增 TopicNameConstants 接口,定义了多个主题名常量
- 新增 TopicTagConstants 接口,定义了多个主题标签常量
This commit is contained in:
HuangLei 2025-06-18 14:55:10 +08:00
parent a81da88bc4
commit d8b10d161e
3 changed files with 96 additions and 0 deletions

View File

@ -0,0 +1,28 @@
package cn.iocoder.yudao.framework.mq.rocketmq.core;
/**
* @author bixuan
* @version 1.0
* @description: TODO
* @date 2025/5/4 10:22
*/
public interface GroupConstants {
String BIND_CARD_PACKAGE_GROUP = "bind-card-package-group";
String UNBIND_CARD_PACKAGE_GROUP = "unbind-card-package-group";
String CHANGE_CARD_PACKAGE_GROUP = "change-card-package-group";
String SYNC_BATCH_GROUP = "sync-batch-group";
String SYNC_CARD_PACKAGE_GROUP = "sync-card-package-group";
String SYNC_CARD_PACKAGE_TRAFFIC_GROUP = "sync-card-package-traffic-group";
String SYNC_CARD_POOL_TRAFFIC_GROUP = "sync-card-pool-traffic-group";
String SYNC_POOL_TRAFFIC_GROUP = "sync-pool-traffic-group";
String SYNC_STATISTICS_CARD_POOL_TRAFFIC_GROUP = "sync-statistics-card-pool-traffic-group";
String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_GROUP = "sync-statistics-card-package-traffic-group";
String PAY_ORDER_DELAY_CLOSE_GROUP = "pay-order-delay-close-group";
String PAY_ORDER_GENERATE_BILL_GROUP = "pay-order-generate-bill-group";
String REFUND_ORDER_WRITE_OFF_BILL_GROUP = "refund-order-write-off-bill-group";
String SYNC_PACKAGE_TRAFFIC_GROUP = "sync-package-traffic-group";
String PAY_ORDER_REFUND_GROUP = "pay-order-refund-group";
String EIOT_CLUB_NOTIFY_SUBPKGLIST_GROUP = "eiot-club-notify-subPkgList-group";
String EIOT_CLUB_NOTIFY_REFUND_GROUP = "eiot-club-notify-refund-group";
}

View File

@ -0,0 +1,41 @@
package cn.iocoder.yudao.framework.mq.rocketmq.core;
/**
* @program: b2b2c-admin
* @ClassName TopicNameConstants
* @description:
* @author: HuangLei
* @create: 2025/4/28/周一 9:55
* @Version 1.0
**/
public interface TopicNameConstants {
/**
* 运营商主题,相同操作消息可以使用tag区分
*/
String IOT_OPERATOR = "iot-operator";
/**
* 事务主题,相同操作消息可以使用tag区分
*/
String IOT_TRANSACTION = "iot-transaction";
/**
* 延时主题,相同操作消息可以使用tag区分
*/
String IOT_DELAY = "iot-delay";
/**
* 退款主题,相同操作消息可以使用tag区分
*/
String PAY_REFUND_ORDER = "pay-refund-order";
/**
* eiotclub异步通知主题
*/
String EIOT_CLUB_NOTIFY_TOPIC = "eiot-club-notify";
}

View File

@ -0,0 +1,27 @@
package cn.iocoder.yudao.framework.mq.rocketmq.core;
/**
* @description: TODO
* @author bixuan
* @date 2025/5/4 10:22
* @version 1.0
*/
public interface TopicTagConstants {
String BIND_CARD_PACKAGE_TAG = "bind_card_package";
String UNBIND_CARD_PACKAGE_TAG = "unbind_card_package";
String CHANGE_CARD_PACKAGE_TAG = "change_card_package";
String SYNC_BATCH_TAG = "sync_batch";
String SYNC_CARD_PACKAGE_TAG = "sync_card_package";
String SYNC_CARD_PACKAGE_TRAFFIC_TAG = "sync_card_package_traffic";
String SYNC_CARD_POOL_TRAFFIC_TAG = "sync_card_pool_traffic";
String SYNC_POOL_TRAFFIC_TAG = "sync_pool_traffic";
String SYNC_STATISTICS_CARD_POOL_TRAFFIC_TAG = "sync_statistics_card_pool_traffic";
String SYNC_STATISTICS_CARD_PACKAGE_TRAFFIC_TAG = "sync_statistics_card_package_traffic";
String PAY_ORDER_SUCCESS_BILL_TAG = "pay_order_success_bill";
String REFUND_SUCCESS_BILL_TAG = "refund_success_bill";
String DELAY_PAY_ORDER_DELAY_CLOSE = "delay_pay_order_close";
}