ScheduledTask.java 文件源码

@Scheduled(fixedRate = 60000,initialDelay=33000)
    public void insertBitstampQuoteXRPUSD() throws InterruptedException {
        Date start = new Date();
        WebClient wc = buildWebClient(URLBS);
        try {
            operations.insert(wc.get().uri("/v2/ticker/xrpusd/").accept(MediaType.APPLICATION_JSON).exchange()
                    .flatMap(response -> response.bodyToMono(QuoteBs.class)).map(res -> {res.setPair("xrpusd"); log.info(res.toString()); return res;})).then().block(Duration.ofSeconds(3));
            log.info("BitstampQuote Xrp Usd " + dateFormat.format(new Date()) + " " + (new Date().getTime()-start.getTime()) + "ms");
        } catch (Exception e) {
//          log.error("Bitstamp insert error", e);
            log.error("Bitstamp Xrp insert error Usd "+ dateFormat.format(new Date()));
        }
    }