src/main/java/cc/mrbird/febs/rabbit/consumer/UsdtUpdateConsumer.java
@@ -40,6 +40,13 @@ @Resource TrxUsdtUpdateService trxUsdtUpdateService; @RabbitListener(queues = RabbitMqConfig.MEMBER_COIN_INSIDE_QUEUE) public void memberCoinInside(Long withdrawId) { log.info("处理用户内部转账的消息:{}#", withdrawId); apiIgtOnHookPlanService.memberCoinInsideMessage(withdrawId); } @RabbitListener(queues = RabbitMqConfig.END_ON_HOOK_QUEUE) public void endOnHook(Long orderId) { log.info("处理用户结束挂机的消息:{}#", orderId);