From 5fe4f4d834929c13bfb5cfc8de5fca20f83df90c Mon Sep 17 00:00:00 2001 From: zainali5120 <512061637@qq.com> Date: Wed, 14 Oct 2020 17:37:45 +0800 Subject: [PATCH] 删除roc数据库配置 --- src/main/java/com/xcong/excoin/rabbit/consumer/ExchangeConsumer.java | 4 ++-- 1 files changed, 2 insertions(+), 2 deletions(-) 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 9670624..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); } /** @@ -124,7 +124,7 @@ */ @RabbitListener(queues = RabbitMqConfig.QUEUE_ROC_ORDER_COMPLETE) public void doComplete(String content) { - log.info("#完成的订单---->{}#", content); + log.debug("#完成的订单---->{}#", content); List<OrderCoinsEntity> exchangeTrades = JSONObject.parseArray(content, OrderCoinsEntity.class); if(CollectionUtils.isEmpty(exchangeTrades)){ return; -- Gitblit v1.9.1