src/main/java/com/xcong/excoin/processor/DefaultCoinProcessor.java
@@ -366,7 +366,7 @@ kLine.setOpen(kLine.getClose()); kLine.setLow(kLine.getClose()); kLine.setHigh(kLine.getClose()); redisUtils.set("ROC/USDT",kLine); redisUtils.set("RFNC/USDT",kLine); } } src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java
@@ -51,7 +51,7 @@ */ @RabbitListener(queues = RabbitMqConfig.QUEUE_TRADE_PLATE) public void tradePlate(String content) { tradePlateSendWebSocket.sendMessagePlate("ROC/USDT",content,null); tradePlateSendWebSocket.sendMessagePlate("RFNC/USDT",content,null); } /**