broker/ServerIntegrationQoSValidationTest: code formatter used

broker/src/test/java/io/moquette/server/ServerIntegrationQoSValidationTest.java

@@ -13,8 +13,8 @@
  *
  * You may elect to redistribute this code under either of these licenses.
  */
-package io.moquette.server;
 
+package io.moquette.server;
 
 import io.moquette.server.config.IConfig;
 import io.moquette.server.config.MemoryConfig;
@@ -29,11 +29,9 @@ import org.junit.BeforeClass;
 import org.junit.Test;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
 import java.io.File;
 import java.io.IOException;
 import java.util.Properties;
-
 import static org.junit.Assert.assertEquals;
 
 /**
@@ -41,13 +39,13 @@ import static org.junit.Assert.assertEquals;
  * @author andrea
  */
 public class ServerIntegrationQoSValidationTest {
-    
+
     private static final Logger LOG = LoggerFactory.getLogger(ServerIntegrationPahoTest.class);
 
     Server m_server;
     static MqttClientPersistence s_subDataStore;
     static MqttClientPersistence s_pubDataStore;
-    
+
     IMqttClient m_subscriber;
     IMqttClient m_publisher;
     MessageCollector m_callback;
@@ -75,7 +73,7 @@ public class ServerIntegrationQoSValidationTest {
         m_callback = new MessageCollector();
         m_subscriber.setCallback(m_callback);
         m_subscriber.connect();
-        
+
         m_publisher = new MqttClient("tcp://localhost:1883", "Publisher", s_pubDataStore);
         m_publisher.connect();
     }
@@ -85,7 +83,7 @@ public class ServerIntegrationQoSValidationTest {
         if (m_publisher.isConnected()) {
             m_publisher.disconnect();
         }
-        
+
         if (m_subscriber.isConnected()) {
             m_subscriber.disconnect();
         }
@@ -93,104 +91,104 @@ public class ServerIntegrationQoSValidationTest {
         m_server.stopServer();
         IntegrationUtils.cleanPersistenceFile(m_config);
     }
-    
+
     @Test
     public void checkSubscriberQoS0ReceiveQoS0publishes() throws Exception {
         LOG.info("*** checkSubscriberQoS0ReceiveQoS0publishes ***");
         m_subscriber.subscribe("/topic", 0);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS0".getBytes(), 0, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS0", message.toString());
         assertEquals(0, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS0ReceiveQoS1publishes_downgrade() throws Exception {
         LOG.info("*** checkSubscriberQoS0ReceiveQoS1publishes_downgrade ***");
         m_subscriber.subscribe("/topic", 0);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS1".getBytes(), 1, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS1", message.toString());
         assertEquals(0, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS0ReceiveQoS2publishes_downgrade() throws Exception {
         LOG.info("*** checkSubscriberQoS0ReceiveQoS2publishes_downgrade ***");
         m_subscriber.subscribe("/topic", 0);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS2".getBytes(), 2, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS2", message.toString());
         assertEquals(0, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS1ReceiveQoS0publishes() throws Exception {
         LOG.info("*** checkSubscriberQoS1ReceiveQoS0publishes ***");
         m_subscriber.subscribe("/topic", 1);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS0".getBytes(), 0, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS0", message.toString());
         assertEquals(0, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS1ReceiveQoS1publishes() throws Exception {
         LOG.info("*** checkSubscriberQoS1ReceiveQoS1publishes ***");
         m_subscriber.subscribe("/topic", 1);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS1".getBytes(), 1, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS1", message.toString());
         assertEquals(1, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS1ReceiveQoS2publishes_downgrade() throws Exception {
         LOG.info("*** checkSubscriberQoS1ReceiveQoS2publishes_downgrade ***");
         m_subscriber.subscribe("/topic", 1);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS2".getBytes(), 2, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS2", message.toString());
         assertEquals(1, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS2ReceiveQoS0publishes() throws Exception {
         LOG.info("*** checkSubscriberQoS2ReceiveQoS0publishes ***");
         m_subscriber.subscribe("/topic", 2);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS2".getBytes(), 0, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS2", message.toString());
         assertEquals(0, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS2ReceiveQoS1publishes() throws Exception {
         LOG.info("*** checkSubscriberQoS2ReceiveQoS1publishes ***");
         m_subscriber.subscribe("/topic", 2);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS2".getBytes(), 1, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS2", message.toString());
         assertEquals(1, message.getQos());
     }
-    
+
     @Test
     public void checkSubscriberQoS2ReceiveQoS2publishes() throws Exception {
         LOG.info("*** checkSubscriberQoS2ReceiveQoS2publishes ***");
         m_subscriber.subscribe("/topic", 2);
-        
+
         m_publisher.publish("/topic", "Hello world MQTT QoS2".getBytes(), 2, false);
         MqttMessage message = m_callback.waitMessage(1);
         assertEquals("Hello world MQTT QoS2", message.toString());
         assertEquals(2, message.getQos());
     }
-    
+
 }