diff --git a/broker/src/test/java/io/moquette/server/ServerIntegrationSSLClientAuthTest.java b/broker/src/test/java/io/moquette/server/ServerIntegrationSSLClientAuthTest.java index e9ec48e0..3868d53b 100644 --- a/broker/src/test/java/io/moquette/server/ServerIntegrationSSLClientAuthTest.java +++ b/broker/src/test/java/io/moquette/server/ServerIntegrationSSLClientAuthTest.java @@ -96,7 +96,7 @@ public class ServerIntegrationSSLClientAuthTest { static MqttClientPersistence s_dataStore; IMqttClient m_client; - TestCallback m_callback; + MessageCollector m_callback; @BeforeClass public static void beforeTests() { @@ -130,7 +130,7 @@ public class ServerIntegrationSSLClientAuthTest { m_client = new MqttClient("ssl://localhost:8883", "TestClient", s_dataStore); // m_client = new MqttClient("ssl://test.mosquitto.org:8883", "TestClient", s_dataStore); - m_callback = new TestCallback(); + m_callback = new MessageCollector(); m_client.setCallback(m_callback); }