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

…transport Set log level `warn` on transport connection error
scalecube · Jul 1, 2020 · 2d04a19 · 2d04a19
2 parents b600886 + 55ebe34
commit 2d04a19
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...port-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java b/...port-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);
             })