src/main/java/cc/mrbird/febs/rabbit/consumer/ChainConsumer.java
@@ -74,4 +74,17 @@ log.error("speedDirectPerkErr:", e); } } /** * speed 卖出资产 */ @RabbitListener(queues = QueueConstants.QUEUE_SPEED_SALE_PACKAGE) public void speedSalePackageMsg(Long memberId) { log.info("speedSalePackageMsg:{}", memberId); try { dappSystemService.speedSalePackageMsg(memberId); } catch (Exception e) { log.error("speedSalePackageErr:", e); } } }