| | |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.FCMPAY_FCM_NFT_EXCHANGE.getExchange(), RabbitQueueEnum.FCMPAY_FCM_NFT_EXCHANGE.getRoute(),value); |
| | | } |
| | | |
| | | public void sendFcmOrderSellInsureMsg(Long sellRecordId) { |
| | | log.info("发送卖单用户确认:{}",sellRecordId); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getExchange(), |
| | | RabbitQueueEnum.FCMPAY_FCM_ORDER_SELL_INSURE.getRoute(),sellRecordId); |
| | | } |
| | | |
| | | public void sendFcmOrderBuyCancelMsg(Long buyRecordId) { |
| | | log.info("发送买单取消:{}",buyRecordId); |
| | | rabbitTemplate.convertAndSend(RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getExchange(), |
| | | RabbitQueueEnum.FCMPAY_FCM_ORDER_BUY_CANCEL.getRoute(),buyRecordId); |
| | | } |
| | | |
| | | /** |
| | | * 发送代理自动升级消息 |
| | | * |