From 964faf360762524aed9dc9eeab73cc9ef08ffe03 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 14 Oct 2020 16:18:56 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/processor/DefaultCoinProcessor.java | 2 +-
src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/processor/DefaultCoinProcessor.java b/src/main/java/com/xcong/excoin/processor/DefaultCoinProcessor.java
index 5873683..7ae14ce 100644
--- a/src/main/java/com/xcong/excoin/processor/DefaultCoinProcessor.java
+++ b/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);
}
}
diff --git a/src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java b/src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java
index 090a3ac..479a47c 100644
--- a/src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java
+++ b/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);
}
/**
--
Gitblit v1.9.1