From f8398a987c97e8557f0611812419ec956c001b27 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Fri, 28 May 2021 11:17:09 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java | 19 ++++++++++--------- 1 files changed, 10 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java b/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java index fb2c49f..fde00a1 100644 --- a/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java +++ b/src/main/java/com/xcong/excoin/quartz/job/BlockCoinUpdateJob.java @@ -49,15 +49,16 @@ // @Async public void usdtTc20Update() { // 波场3秒出一个块 - Long blocnNum = TRC_BLOCK.poll(); - log.info("------>{}", blocnNum); - if (blocnNum == null) { - return; - } - log.info("=====>>{}", blocnNum); - usdtUpdateProducer.sendTrc20BlockMsg(blocnNum.toString()); - redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum); - log.info("------>>>>{}", blocnNum); + log.info("============"); +// Long blocnNum = TRC_BLOCK.poll(); +// log.info("------>{}", blocnNum); +// if (blocnNum == null) { +// return; +// } +// log.info("=====>>{}", blocnNum); +// usdtUpdateProducer.sendTrc20BlockMsg(blocnNum.toString()); +// redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum); +// log.info("------>>>>{}", blocnNum); // try { // trxUsdtUpdateService.monitorCoinListener(blocnNum); // } catch (RestClientException | HttpException e) { -- Gitblit v1.9.1