| | |
| | | // @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) { |