From f812dd42487c1ee47cb9bcbeed1f40779bbae6aa Mon Sep 17 00:00:00 2001 From: wzy <wzy19931122ai@163.com> Date: Thu, 15 Oct 2020 20:09:04 +0800 Subject: [PATCH] modify --- 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