fixing code style

Author: Ricore72

spring-integration-mqtt/src/test/java/org/springframework/integration/mqtt/ClientManagerBackToBackTests.java

@@ -18,7 +18,6 @@
 
 import java.lang.reflect.Constructor;
 import java.nio.charset.StandardCharsets;
-import java.util.Arrays;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
@@ -83,7 +82,7 @@ void testV3ClientManagerStarted() throws Exception {
 	}
 
 	@Test
-	void testV3ClientManagerRuntime() throws Exception{
+	void testV3ClientManagerRuntime() throws Exception {
 		testSubscribeAndPublishRuntime(Mqttv3ConfigRuntime.class, Mqttv3ConfigRuntime.TOPIC_NAME,
 				Mqttv3ConfigRuntime.subscribedLatch, Mqttv3ConfigRuntime.adapter);
 	}
@@ -101,7 +100,7 @@ void testV5ClientManagerStarted() throws Exception {
 	}
 
 	@Test
-	void testV5ClientManagerRuntime() throws Exception{
+	void testV5ClientManagerRuntime() throws Exception {
 		testSubscribeAndPublishRuntime(Mqttv5ConfigRuntime.class, Mqttv5ConfigRuntime.TOPIC_NAME,
 				Mqttv5ConfigRuntime.subscribedLatch, Mqttv5ConfigRuntime.adapter);
 	}
@@ -144,7 +143,7 @@ private void testSubscribeAndPublishRuntime(Class<?> configClass, String topicNa
 			Class<?>[] parameterTypes = {ClientManager.class, String[].class};
 			Constructor<?> declaredConstructor = adapter.getConstructor(parameterTypes);
 			flowContext.registration(IntegrationFlow
-					.from((MessageProducerSupport) declaredConstructor.newInstance(clientManager,new String[] {topicName}))
+					.from((MessageProducerSupport) declaredConstructor.newInstance(clientManager, new String[] {topicName}))
 					.channel(output)
 					.get()).register();
 			String testPayload = "foo";
@@ -277,6 +276,7 @@ public IntegrationFlow mqttInFlow(Mqttv3ClientManager mqttv3ClientManager) {
 		}
 
 	}
+
 	@Configuration
 	@EnableIntegration
 	public static class Mqttv3ConfigRuntime {
@@ -297,7 +297,7 @@ public Mqttv3ClientManager mqttv3ClientManager() {
 			MqttConnectOptions connectionOptions = new MqttConnectOptions();
 			connectionOptions.setServerURIs(new String[] {MosquittoContainerTest.mqttUrl()});
 			connectionOptions.setAutomaticReconnect(true);
-            return new Mqttv3ClientManager(connectionOptions, "client-manager-client-id-v3");
+			return new Mqttv3ClientManager(connectionOptions, "client-manager-client-id-v3");
 		}
 
 		@Bean
@@ -411,6 +411,7 @@ public IntegrationFlow mqttInFlow(Mqttv5ClientManager mqttv5ClientManager) {
 		}
 
 	}
+
 	@Configuration
 	@EnableIntegration
 	public static class Mqttv5ConfigRuntime {