Polishing

[#187]

Author: mp911de

src/main/java/io/r2dbc/postgresql/PostgresqlConnectionFactory.java

@@ -37,6 +37,7 @@
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
+import reactor.util.annotation.Nullable;
 
 import java.util.ArrayList;
 import java.util.List;
@@ -147,7 +148,7 @@ private Throwable cannotConnect(Throwable throwable) {
             return throwable;
         }
 
-        return new R2dbcNonTransientResourceException(
+        return new PostgresConnectionException(
             String.format("Cannot connect to %s:%d", this.configuration.getHost(), this.configuration.getPort()), throwable
         );
     }
@@ -206,4 +207,11 @@ private Mono<Void> setSchema(PostgresqlConnection connection) {
             .then();
     }
 
+    static class PostgresConnectionException extends R2dbcNonTransientResourceException {
+
+        public PostgresConnectionException(String msg, @Nullable Throwable cause) {
+            super(msg, cause);
+        }
+    }
+
 }