From 4a1e4abf6ed1deafdb293d3aa85d099ef5c63a1a Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Tue, 14 Jun 2022 11:28:23 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java | 20 ++++++++++---------- 1 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java b/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java index db87fae..b2b5d33 100644 --- a/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java +++ b/src/main/java/cc/mrbird/febs/job/NewPriceUpdateJob.java @@ -11,7 +11,7 @@ import javax.annotation.PostConstruct; /** - * @author wzy + * @author * @date 2022-03-24 **/ @Slf4j @@ -23,14 +23,14 @@ @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()); +// }); } } -- Gitblit v1.9.1