Fix expected type of pg_terminate_backend result in testNoConnectionLeaks

Author: kdubb

vertx-pg-client/src/test/java/io/vertx/pgclient/PgPoolTest.java

@@ -384,7 +384,7 @@ public void testPipeliningDistribution(TestContext ctx) {
   public void testPoolIdleTimeout(TestContext ctx) {
     ProxyServer proxy = ProxyServer.create(vertx, options.getPort(), options.getHost());
     AtomicReference<ProxyServer.Connection> proxyConn = new AtomicReference<>();
-    int pooleCleanerPeriod = 100;
+    int poolCleanerPeriod = 100;
     int idleTimeout = 3000;
     Async latch = ctx.async();
     proxy.proxyHandler(conn -> {
@@ -393,8 +393,8 @@ public void testPoolIdleTimeout(TestContext ctx) {
       conn.clientCloseHandler(v -> {
         long lifetime = System.currentTimeMillis() - now;
         int delta = 500;
-        int lowerBound = idleTimeout - pooleCleanerPeriod - delta;
-        int upperBound = idleTimeout + pooleCleanerPeriod + delta;
+        int lowerBound = idleTimeout - poolCleanerPeriod - delta;
+        int upperBound = idleTimeout + poolCleanerPeriod + delta;
         ctx.assertTrue(lifetime >= lowerBound, "Was expecting connection to be closed in more than " + lowerBound + ": " + lifetime);
         ctx.assertTrue(lifetime <= upperBound, "Was expecting connection to be closed in less than " + upperBound + ": "+ lifetime);
         latch.complete();
@@ -408,7 +408,7 @@ public void testPoolIdleTimeout(TestContext ctx) {
     listenLatch.awaitSuccess(20_000);
 
     poolOptions
-      .setPoolCleanerPeriod(pooleCleanerPeriod)
+      .setPoolCleanerPeriod(poolCleanerPeriod)
       .setMaxLifetime(0)
       .setIdleTimeout(idleTimeout)
       .setIdleTimeoutUnit(TimeUnit.MILLISECONDS);
@@ -427,7 +427,7 @@ public void testPoolIdleTimeout(TestContext ctx) {
   public void testPoolMaxLifetime(TestContext ctx) {
     ProxyServer proxy = ProxyServer.create(vertx, options.getPort(), options.getHost());
     AtomicReference<ProxyServer.Connection> proxyConn = new AtomicReference<>();
-    int pooleCleanerPeriod = 100;
+    int poolCleanerPeriod = 100;
     int maxLifetime = 3000;
     Async latch = ctx.async();
     proxy.proxyHandler(conn -> {
@@ -436,8 +436,8 @@ public void testPoolMaxLifetime(TestContext ctx) {
       conn.clientCloseHandler(v -> {
         long lifetime = System.currentTimeMillis() - now;
         int delta = 500;
-        int lowerBound = maxLifetime - pooleCleanerPeriod - delta;
-        int upperBound = maxLifetime + pooleCleanerPeriod + delta;
+        int lowerBound = maxLifetime - poolCleanerPeriod - delta;
+        int upperBound = maxLifetime + poolCleanerPeriod + delta;
         ctx.assertTrue(lifetime >= lowerBound, "Was expecting connection to be closed in more than " + lowerBound + ": " + lifetime);
         ctx.assertTrue(lifetime <= upperBound, "Was expecting connection to be closed in less than " + upperBound + ": "+ lifetime);
         latch.complete();
@@ -451,7 +451,7 @@ public void testPoolMaxLifetime(TestContext ctx) {
     listenLatch.awaitSuccess(20_000);
 
     poolOptions
-      .setPoolCleanerPeriod(pooleCleanerPeriod)
+      .setPoolCleanerPeriod(poolCleanerPeriod)
       .setIdleTimeout(0)
       .setMaxLifetime(maxLifetime)
       .setMaxLifetimeUnit(TimeUnit.MILLISECONDS);
@@ -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()));
     }));