Merge pull request #346 from scalecube/set-log-level-warn-in-cluster-transport

Set log level `warn` on transport connection error

Author: artem-v

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java

@@ -241,7 +241,7 @@ private Message toMessage(ByteBuf byteBuf) {
     try (ByteBufInputStream stream = new ByteBufInputStream(byteBuf, true)) {
       return messageCodec.deserialize(stream);
     } catch (Exception e) {
-      LOGGER.warn("[{}][toMessage] Exception occurred: {}", address, e.toString());
+      LOGGER.warn("[{}][decodeMessage] Exception occurred: {}", address, e.toString());
       throw new DecoderException(e);
     }
   }
@@ -253,7 +253,7 @@ private ByteBuf toByteBuf(Message message) {
       messageCodec.serialize(message, stream);
     } catch (Exception e) {
       byteBuf.release();
-      LOGGER.warn("[{}][toByteBuf] Exception occurred: {}", address, e.toString());
+      LOGGER.warn("[{}][encodeMessage] Exception occurred: {}", address, e.toString());
       throw new EncoderException(e);
     }
     return byteBuf;
@@ -270,7 +270,7 @@ private Mono<? extends Connection> connect0(Address address1) {
             })
         .doOnError(
             th -> {
-              LOGGER.debug(
+              LOGGER.warn(
                   "[{}][connect0][{}] Exception occurred: {}", address, address1, th.toString());
               connections.remove(address1);
             })