Fix usage of NioParams setter in test

References #396,#715

Author: acogoluegnes

src/test/java/com/rabbitmq/client/test/ssl/NioTlsUnverifiedConnection.java

@@ -98,8 +98,9 @@ public void connectionGetConsumeProtocols() throws Exception {
             cf.useSslProtocol(sslContext);
             cf.useNio();
             AtomicReference<SSLEngine> engine = new AtomicReference<>();
-            cf.setNioParams(new NioParams()
-                    .setSslEngineConfigurator(sslEngine -> engine.set(sslEngine)));
+            NioParams nioParams = new NioParams();
+            nioParams.setSslEngineConfigurator(sslEngine -> engine.set(sslEngine));
+            cf.setNioParams(nioParams);
             try (Connection c = cf.newConnection()) {
                 CountDownLatch latch = new CountDownLatch(1);
                 basicGetBasicConsume(c, QUEUE, latch, 100);

src/test/java/com/rabbitmq/client/test/ssl/VerifiedConnection.java

@@ -83,10 +83,11 @@ public void connectionGetConsumeProtocols() throws Exception {
             AtomicReference<Supplier<String[]>> protocolsSupplier = new AtomicReference<>();
             if (TestUtils.USE_NIO) {
                 cf.useNio();
-                cf.setNioParams(new NioParams()
-                    .setSslEngineConfigurator(sslEngine -> {
-                        protocolsSupplier.set(() -> sslEngine.getEnabledProtocols());
-                    }));
+                NioParams nioParams = new NioParams();
+                nioParams.setSslEngineConfigurator(
+                    sslEngine -> protocolsSupplier.set(() -> sslEngine.getEnabledProtocols())
+                );
+                cf.setNioParams(nioParams);
             } else {
                 cf.setSocketConfigurator(socket -> {
                     SSLSocket s = (SSLSocket) socket;