ScheduledTask.java 文件源码

@Scheduled(fixedRate = 60000,initialDelay=42000)
    public void insertBitfinexQuoteLTCUSD() throws InterruptedException {
        Date start = new Date();
        WebClient wc = buildWebClient(URLBF);       
        try {
            operations.insert(wc.get().uri("/v1/pubticker/ltcusd").accept(MediaType.APPLICATION_JSON).exchange()
                    .flatMap(response -> response.bodyToMono(QuoteBf.class)).map(res -> {res.setPair("ltcusd"); log.info(res.toString()); return res;})).then().block(Duration.ofSeconds(3));
            log.info("BitfinexQuote Ltc Usd " + dateFormat.format(new Date()) + " " + (new Date().getTime()-start.getTime()) + "ms");
        } catch (Exception e) {
//          log.error("Bitstamp insert error", e);
            log.error("Bitfinex Ltc insert error Usd "+ dateFormat.format(new Date()));
        }
    }