bitrich-info/xchange-stream

Coinbase Pro recv-Q too high

Closed this issue · 0 comments

What I observe from logs are Recv-Q for CoinbasePro is too high... which results very high lags comparing to coinbase official data

tcp6 0 0 ip-172-31-33-235.:53048 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:53064 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:53016 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:60460 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:53022 104.18.171.35:https ESTABLISHED
tcp6 5049361 0 ip-172-31-33-235.:53028 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:60440 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:53042 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:44342 104.16.233.188:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:60412 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:60426 104.18.171.35:https ESTABLISHED
tcp6 0 0 ip-172-31-33-235.:60458 104.18.171.35:https ESTABLISHED

------- code -------

` ProductSubscriptionBuilder builder = ProductSubscription.create();

	builder.addOrderbook(new CurrencyPair("BTC/USD");
	ProductSubscription sub = builder.build();
	this.exchange.connect(sub).blockingAwait();

	Disposable disposibleSubscription = exchange.getStreamingMarketDataService()
			.getOrderBook(new CurrencyPair("BTC/USD"), 10)
			.subscribe(orderBook -> {
				try {

                                             ....

				}
				catch (Exception ex) {

					Date d = new Date();
					System.err.println("CoinbaseMarketDataClient Exception thrown at " + d.toString());
					ex.printStackTrace();
					LOGGER.error("CoinbaseMarketDataClient Exception thrown in disposibleSubscription", ex);
				}
			}, err-> { err.printStackTrace(); });`