diff --git a/broker/src/test/java/io/moquette/server/ServerIntegrationQoSValidationTest.java b/broker/src/test/java/io/moquette/server/ServerIntegrationQoSValidationTest.java index 83be0c9f..9a6fcbb6 100644 --- a/broker/src/test/java/io/moquette/server/ServerIntegrationQoSValidationTest.java +++ b/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()); } - + }