From e5e3bc5b8f863ce8f1069a12350432ea8cfbf965 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Fri, 26 Feb 2021 15:31:18 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/quartz/job/KLineDataJob.java | 39 +++++++++++++++++++++++++++++++++------
1 files changed, 33 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/quartz/job/KLineDataJob.java b/src/main/java/com/xcong/excoin/quartz/job/KLineDataJob.java
index cd6cae0..2463a60 100644
--- a/src/main/java/com/xcong/excoin/quartz/job/KLineDataJob.java
+++ b/src/main/java/com/xcong/excoin/quartz/job/KLineDataJob.java
@@ -26,22 +26,49 @@
@Autowired
WebSocketServer webSocketServer;
- @PostConstruct
+ @Autowired
+ private SubscriptionClient subscriptionClient;
+
+// @PostConstruct
public void data() throws Exception {
webSocketServer.start();
log.info("==================");
- SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
- subscriptionOptions.setConnectionDelayOnFailure(5);
- subscriptionOptions.setUri("wss://api.hadax.com/ws");
- SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.DAY1, (candlestickEvent) -> {
Candlestick data = candlestickEvent.getData();
});
- subscriptionClient.subscribePriceDepthEvent("btcusdt", priceDepthEvent -> {
+// subscriptionClient.subscribePriceDepthEvent("btcusdt", priceDepthEvent -> {
// log.info("bids:{}", JSONObject.toJSONString(priceDepthEvent.getData().getBids()));
// log.info("asks:{}", JSONObject.toJSONString(priceDepthEvent.getData().getAsks()));
+// });
+
+ subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN1, (candlestickEvent) -> {
+ Candlestick data = candlestickEvent.getData();
+ });
+
+ subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN5, (candlestickEvent) -> {
+ Candlestick data = candlestickEvent.getData();
+ });
+
+ subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN15, (candlestickEvent) -> {
+ Candlestick data = candlestickEvent.getData();
+ });
+
+ subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN60, (candlestickEvent) -> {
+ Candlestick data = candlestickEvent.getData();
+ });
+
+ subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.HOUR4, (candlestickEvent) -> {
+ Candlestick data = candlestickEvent.getData();
+ });
+
+ subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.DAY1, (candlestickEvent) -> {
+ Candlestick data = candlestickEvent.getData();
+ });
+
+ subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.WEEK1, (candlestickEvent) -> {
+ Candlestick data = candlestickEvent.getData();
});
}
}
--
Gitblit v1.9.1