| | |
| | | |
| | | @PostConstruct |
| | | public void initNewPriceUpdate() { |
| | | log.info("#最新价更新启动#"); |
| | | redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30); |
| | | SubscriptionOptions subscriptionOptions = new SubscriptionOptions(); |
| | | subscriptionOptions.setConnectionDelayOnFailure(5); |
| | | subscriptionOptions.setUri("wss://api.hadax.com/ws"); |
| | | SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions); |
| | | subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> { |
| | | redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice()); |
| | | }); |
| | | // log.info("#最新价更新启动#"); |
| | | // redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30); |
| | | // SubscriptionOptions subscriptionOptions = new SubscriptionOptions(); |
| | | // subscriptionOptions.setConnectionDelayOnFailure(5); |
| | | // subscriptionOptions.setUri("wss://api.hadax.com/ws"); |
| | | // SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions); |
| | | // subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> { |
| | | // redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice()); |
| | | // }); |
| | | } |
| | | } |