diff --git a/vertx-pg-client/src/test/java/io/vertx/pgclient/PgPoolTest.java b/vertx-pg-client/src/test/java/io/vertx/pgclient/PgPoolTest.java
index bedadc8b2..87104aa30 100644
--- a/vertx-pg-client/src/test/java/io/vertx/pgclient/PgPoolTest.java
+++ b/vertx-pg-client/src/test/java/io/vertx/pgclient/PgPoolTest.java
@@ -507,9 +507,9 @@ public void testPoolConnectTimeout(TestContext ctx) {
   public void testNoConnectionLeaks(TestContext ctx) {
     Async killConnections = ctx.async();
     PgConnection.connect(vertx, options).onComplete(ctx.asyncAssertSuccess(conn -> {
-      Collector<Row, ?, List<Integer>> collector = mapping(row -> row.getInteger(0), toList());
+      Collector<Row, ?, List<Boolean>> collector = mapping(row -> row.getBoolean(0), toList());
       String sql = "SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE pid <> pg_backend_pid() AND datname = $1";
-      PreparedQuery<SqlResult<List<Integer>>> preparedQuery = conn.preparedQuery(sql).collecting(collector);
+      PreparedQuery<SqlResult<List<Boolean>>> preparedQuery = conn.preparedQuery(sql).collecting(collector);
       Tuple params = Tuple.of(options.getDatabase());
       preparedQuery.execute(params).compose(cf -> conn.close()).onComplete(ctx.asyncAssertSuccess(v -> killConnections.complete()));
     }));