xiaoyong931011
2023-08-15 76706e083e2f5d91b4d3346ffead2e6bce2d09c5
src/main/java/cc/mrbird/febs/rabbit/producer/ChainProducer.java
@@ -77,10 +77,10 @@
    /**
     * speed 卖出资产
     */
    public void sendSalePackageMsg(@NotNull Long memberId) {
        log.info("sendSalePackageMsg:{}", memberId);
    public void sendSalePackageMsg(@NotNull Long flowId) {
        log.info("sendSalePackageMsg:{}", flowId);
        CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());
        rabbitTemplate.convertAndSend(QueueEnum.SPEED_SALE_PACKAGE.getExchange(), QueueEnum.SPEED_SALE_PACKAGE.getRoute(), memberId, correlationData);
        rabbitTemplate.convertAndSend(QueueEnum.SPEED_SALE_PACKAGE.getExchange(), QueueEnum.SPEED_SALE_PACKAGE.getRoute(), flowId, correlationData);
    }
}