File tree Expand file tree Collapse file tree
bitmex-adapter/src/com/bookmap/plugins/layer0/bitmex/adapter Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -295,7 +295,7 @@ public void run() {
295295 }
296296
297297 if (!instr .isOrderBookSnapshotParsed ()) {
298- Log .info ("[bitmex] BmConnector launchSnapshotTimer " + localTimerCount + " for" + instr .getSymbol () + ": resubscribe " + ZonedDateTime .now (ZoneOffset .UTC ));
298+ Log .info ("[bitmex] BmConnector launchSnapshotTimer " + localTimerCount + " for " + instr .getSymbol () + ": resubscribe " + ZonedDateTime .now (ZoneOffset .UTC ));
299299 unSubscribe (instr );
300300
301301 try {
@@ -306,14 +306,14 @@ public void run() {
306306
307307 subscribe (instr );
308308 } else {
309- Log .info ("[bitmex] BmConnector launchSnapshotTimer " + localTimerCount + " for" + instr .getSymbol () + ": end " + ZonedDateTime .now (ZoneOffset .UTC ));
309+ Log .info ("[bitmex] BmConnector launchSnapshotTimer " + localTimerCount + " for " + instr .getSymbol () + ": end " + ZonedDateTime .now (ZoneOffset .UTC ));
310310 }
311311 }
312312 };
313313
314314 Timer timer = new Timer ();
315315 instr .setSnapshotTimer (timer );
316- Log .info ("[bitmex] BmConnector launchSnapshotTimer " + localTimerCount + " for" + instr .getSymbol () + ": " + ZonedDateTime .now (ZoneOffset .UTC ));
316+ Log .info ("[bitmex] BmConnector launchSnapshotTimer " + localTimerCount + " for " + instr .getSymbol () + ": " + ZonedDateTime .now (ZoneOffset .UTC ));
317317 timer .schedule (task , 10000 );
318318 timerCount ++;
319319 }
Original file line number Diff line number Diff line change @@ -20,10 +20,6 @@ public class BmInstrument {
2020 private long underlyingToSettleMultiplier ;
2121 private String settlCurrency ;
2222 private boolean isSubscribed = false ;
23- private boolean isFirstSnapshotParsed = false ;
24-
25- // this one is for 'orderBookL2 and for 'trade'
26- // private Map<String, Boolean> instrumentPartialsParsed = new HashMap<>();
2723
2824 private OrderBook orderBook = new OrderBook ();
2925 private BlockingQueue <Message > queue = new LinkedBlockingQueue <>();
You can’t perform that action at this time.
0 commit comments