| | |
| | | CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); |
| | | rabbitTemplate.convertAndSend(QueueEnum.NFT_BOX.getExchange(), QueueEnum.NFT_BOX.getRoute(), id, correlationData); |
| | | } |
| | | |
| | | /** |
| | | * 消费者在矩阵项目 |
| | | * @param data |
| | | */ |
| | | public void sendTfcNewPrice(String data) { |
| | | log.info("发送tfc最新价:{}", data); |
| | | CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString()); |
| | | rabbitTemplate.convertAndSend(QueueEnum.TFC_NEW_PRICE.getExchange(), QueueEnum.TFC_NEW_PRICE.getRoute(), data, correlationData); |
| | | } |
| | | } |