| | |
|---|
| | | @Resource |
|---|
| | | TrxUsdtUpdateService trxUsdtUpdateService; |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private RedisUtils redisUtils; |
|---|
| | | |
|---|
| | | |
|---|
| | | @RabbitListener(queues = RabbitMqConfig.QUEUE_USDT_UPDATE) |
|---|
| | | public void doSomething(String content) { |
|---|
| | | log.info("#USDT同步---->{}#", content); |
|---|
| | |
|---|
| | | @RabbitListener(queues = RabbitMqConfig.QUEUE_TRC20_BLOCK) |
|---|
| | | public void trc20BlockMsg(String content) { |
|---|
| | | Long blocnNum = Long.parseLong(content); |
|---|
| | | redisUtils.set("USDT_TRC20_CURRENT_BLOCK_NUM", blocnNum); |
|---|
| | | try { |
|---|
| | | trxUsdtUpdateService.monitorCoinListener(blocnNum); |
|---|
| | | } catch (RestClientException | HttpException e) { |
|---|
