From b31ae14c493b58c21d8c4cb78d3ffd38bbd5dea5 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Thu, 19 Dec 2024 16:53:29 +0800 Subject: [PATCH] refactor(mall): 优化团队信息初始化和数据结构 --- src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java | 25 ++++++++++++++++++------- 1 files changed, 18 insertions(+), 7 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java b/src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java index 90122ca..b50a883 100644 --- a/src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java +++ b/src/main/java/cc/mrbird/febs/rabbit/enumerates/RabbitQueueEnum.java @@ -1,18 +1,29 @@ package cc.mrbird.febs.rabbit.enumerates; +import cc.mrbird.febs.rabbit.constants.ExchangeConstants; +import cc.mrbird.febs.rabbit.constants.QueueConstants; +import cc.mrbird.febs.rabbit.constants.RouteKeyConstants; import lombok.Getter; @Getter public enum RabbitQueueEnum { - DEFAULT("exchange_default", "route_key_default", "queue_default"), + /** + * 购买成功消息 + */ + RUN_VIP_OPERATION_CHARGE(ExchangeConstants.RUN_VIP_OPERATION_CHARGE, + RouteKeyConstants.RUN_VIP_OPERATION_CHARGE, + QueueConstants.RUN_VIP_OPERATION_CHARGE), - ORDER_CANCEL_DELAY_TTL("exchange_order_delay_ttl", "route_key_order_delay_ttl", "queue_order_delay_ttl"), - ORDER_CANCEL_DELAY("exchange_order_delay", "route_key_order_delay", "queue_order_delay"), - - AGENT_REUTRN_MONEY("exchange_agent_return_money", "route_key_agent_return_money", "queue_agent_return_money"), - - ORDER_RETURN_MONEY("exchange_order_return_money", "route_key_order_return_money", "queue_order_return_money"); + /** + * 充值自动过期 + */ + RUN_VIP_OPERATION_CHARGE_FAIL(ExchangeConstants.RUN_VIP_OPERATION_CHARGE_FAIL, + RouteKeyConstants.RUN_VIP_OPERATION_CHARGE_FAIL, + QueueConstants.RUN_VIP_OPERATION_CHARGE_FAIL), + RUN_VIP_OPERATION_CHARGE_FAIL_TTL(ExchangeConstants.RUN_VIP_OPERATION_CHARGE_FAIL_TTL, + RouteKeyConstants.RUN_VIP_OPERATION_CHARGE_FAIL_TTL, + QueueConstants.RUN_VIP_OPERATION_CHARGE_FAIL_TTL),; private String exchange; -- Gitblit v1.9.1