fix: reduce log level for conection reset

xchange-poloniex/src/test/java/org/knowm/xchange/poloniex/service/marketdata/CandleStickTest.java

@@ -0,0 +1,41 @@
+package org.knowm.xchange.poloniex.service.marketdata;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+import java.time.Instant;
+import java.time.temporal.ChronoUnit;
+import java.util.Date;
+import org.junit.Test;
+import org.knowm.xchange.Exchange;
+import org.knowm.xchange.ExchangeFactory;
+import org.knowm.xchange.currency.CurrencyPair;
+import org.knowm.xchange.dto.marketdata.CandleStickData;
+import org.knowm.xchange.dto.marketdata.Ticker;
+import org.knowm.xchange.instrument.Instrument;
+import org.knowm.xchange.poloniex.PoloniexExchange;
+import org.knowm.xchange.service.marketdata.MarketDataService;
+import org.knowm.xchange.service.trade.params.DefaultCandleStickParam;
+
+/**
+ * @author timmolter
+ */
+public class CandleStickTest {
+
+  @Test
+  public void tickerFetchTest() throws Exception {
+
+    Exchange exchange = ExchangeFactory.INSTANCE.createExchange(PoloniexExchange.class);
+    exchange.remoteInit();
+    MarketDataService marketDataService = exchange.getMarketDataService();
+    Instrument instrument = exchange.getExchangeMetaData().getInstruments().keySet().iterator().next();
+
+    Instant now = Instant.now();
+    Date endDate = Date.from(now);
+    Date startDate = Date.from(now.minus(1, ChronoUnit.DAYS));
+    CurrencyPair currencyPair = new CurrencyPair(instrument.getBase(), instrument.getCounter());
+    CandleStickData ticker = marketDataService.getCandleStickData(currencyPair,new DefaultCandleStickParam(
+        startDate, endDate, 60*60));
+    System.out.println(ticker.toString());
+    assertThat(ticker).isNotNull();
+  }
+}

xchange-stream-service-netty/src/main/java/info/bitrich/xchangestream/service/netty/WebSocketClientHandler.java

@@ -19,10 +19,12 @@
 import org.slf4j.LoggerFactory;
 
 public class WebSocketClientHandler extends SimpleChannelInboundHandler<Object> {
+
   private static final Logger LOG = LoggerFactory.getLogger(WebSocketClientHandler.class);
   private final StringBuilder currentMessage = new StringBuilder();
 
   public interface WebSocketMessageHandler {
+
     public void onMessage(String message);
   }
 
@@ -114,15 +116,24 @@ private void dealWithContinuation(ContinuationWebSocketFrame frame) {
 
   @Override
   public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
-    LOG.error(
-        "WebSocket client {} encountered exception ({} - {}). Closing",
-        ctx.channel(),
-        cause.getClass().getSimpleName(),
-        cause.getMessage(),
-        cause);
+    if (cause.getMessage() != null && cause.getMessage().toLowerCase()
+        .contains("connection reset")) {
+      LOG.warn(
+          "WebSocket client {} encountered exception ({} - {}). Closing",
+          ctx.channel(),
+          cause.getClass().getSimpleName(),
+          cause.getMessage());
+    } else {
+      LOG.error(
+          "WebSocket client {} encountered exception ({} - {}). Closing",
+          ctx.channel(),
+          cause.getClass().getSimpleName(),
+          cause.getMessage(),
+          cause);
+    }
     if (!handshakeFuture.isDone()) {
       handshakeFuture.setFailure(cause);
     }
     ctx.close();
   }
-}
+}