| | |
|---|
| | | |
|---|
| | | @PostConstruct |
|---|
| | | public void initNewestPrice() { |
|---|
| | | try{ |
|---|
| | | log.info("#=======价格更新开启=======#"); |
|---|
| | | SubscriptionOptions subscriptionOptions = new SubscriptionOptions(); |
|---|
| | | subscriptionOptions.setConnectionDelayOnFailure(5); |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | }); |
|---|
| | | }catch (Exception e){ |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | // subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.DAY1, (candlestickEvent) -> { |
|---|
| | | // Candlestick data = candlestickEvent.getData(); |
|---|
| | | // redisUtils.set(CoinTypeConvert.convert(candlestickEvent.getSymbol()), data); |
|---|
