Polishing tcp support for port numbers.

Related to #86
r2dbc · Aug 15, 2019 · 8edb8a6 · 8edb8a6
1 parent 6bdcf8e
commit 8edb8a6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/java/io/r2dbc/h2/H2ConnectionConfiguration.java b/src/main/java/io/r2dbc/h2/H2ConnectionConfiguration.java
@@ -140,7 +140,7 @@ public Builder tcp(String host, String path) {
          * @param path - path of the database, e.g. {@code ~/test} resolves to {user.home}/test.db
          * @return this {@link Builder}
          */
-        public Builder tcp(String host, String port, String path) {
+        public Builder tcp(String host, int port, String path) {
             return url(String.format("tcp://%s:%s/%s", host, port, path));
         }
 

diff --git a/src/test/java/io/r2dbc/h2/H2RemoteAccessTest.java b/src/test/java/io/r2dbc/h2/H2RemoteAccessTest.java
@@ -67,7 +67,7 @@ void tcpWithHostnameAndPortWorks() throws IOException {
         FileSystemUtils.deleteRecursively(Paths.get(System.getProperty("user.home"), "test.trace.db"));
 
         H2ConnectionConfiguration configuration = H2ConnectionConfiguration.builder()
-            .tcp("localhost", "9123", "~/test")
+            .tcp("localhost", 9123, "~/test")
             .username("sa")
             .password("")
             .build();