diff --git a/artemis-protocols/artemis-mqtt-protocol/pom.xml b/artemis-protocols/artemis-mqtt-protocol/pom.xml index 7a98856183..50e08ec8da 100644 --- a/artemis-protocols/artemis-mqtt-protocol/pom.xml +++ b/artemis-protocols/artemis-mqtt-protocol/pom.xml @@ -115,12 +115,6 @@ org.eclipse.paho.mqttv5.client test - - com.github.javafaker - javafaker - 0.15 - test - org.awaitility awaitility diff --git a/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTRetainMessageManagerTest.java b/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTRetainMessageManagerTest.java index e21c63b658..f54f66aeba 100644 --- a/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTRetainMessageManagerTest.java +++ b/artemis-protocols/artemis-mqtt-protocol/src/test/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTRetainMessageManagerTest.java @@ -33,6 +33,7 @@ import org.apache.activemq.artemis.core.server.MessageReference; import org.apache.activemq.artemis.core.server.Queue; import org.apache.activemq.artemis.junit.EmbeddedJMSResource; import org.apache.activemq.artemis.utils.collections.LinkedListIterator; +import org.apache.commons.lang3.RandomStringUtils; import org.eclipse.paho.client.mqttv3.MqttException; import org.eclipse.paho.client.mqttv3.MqttMessage; import org.junit.After; @@ -44,9 +45,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.lang.invoke.MethodHandles; -import com.github.javafaker.ChuckNorris; -import com.github.javafaker.Faker; - @SuppressWarnings("deprecation") public class MQTTRetainMessageManagerTest { @@ -74,8 +72,6 @@ public class MQTTRetainMessageManagerTest { private final String topic = "fact"; - private final ChuckNorris chuckNorris = (new Faker()).chuckNorris(); - private final int numberOfMessages = 1000; private final int numberOfTests = 10; @@ -186,7 +182,7 @@ public class MQTTRetainMessageManagerTest { protected void publish(final int qos) throws MqttException { mqttConsumerCount.subscribe(topic, qos); IntStream.range(0, numberOfMessages).forEach(i -> { - final String fact = String.format("[%s] %s", i, chuckNorris.fact()); + final String fact = String.format("[%s] %s", i, RandomStringUtils.randomAlphanumeric(128)); final MqttMessage message = message(fact, qos, true); mqttPublisher.publish(topic, message); lastMessagePublished.set(message);