Refine error logging.

[#458] Signed-off-by: Mark Paluch <mpaluch@vmware.com>
pgjdbc · Oct 19, 2021 · ca4dd62 · ca4dd62
1 parent e8c92a3
commit ca4dd62
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/main/java/io/r2dbc/postgresql/client/ReactorNettyClient.java b/src/main/java/io/r2dbc/postgresql/client/ReactorNettyClient.java
@@ -150,10 +150,7 @@ private ReactorNettyClient(Connection connection, ConnectionSettings settings) {
 
         connection.inbound().receive()
             .map(BackendMessageDecoder::decode)
-            .doOnError(throwable -> {
-                receiveError.set(throwable);
-                handleConnectionError(throwable);
-            })
+            .doOnError(receiveError::set)
             .<BackendMessage>handle((backendMessage, sink) -> {
 
                 if (consumeMessage(backendMessage)) {
@@ -235,7 +232,7 @@ private Mono<Void> resumeError(Throwable throwable) {
         if (isSslException(throwable)) {
             logger.debug(this.context.getMessage("Connection Error"), throwable);
         } else {
-            logger.error(this.context.getMessage("Connection Error"), throwable);
+            logger.warn(this.context.getMessage("Connection Error"), throwable);
         }
 
         return close();