Helius
2022-08-12 5e0c0bacadab898152518437ceb63bf8b54c6652
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());
//        });
    }
}