Fixed failing tests

broker/src/main/java/io/moquette/broker/IRetainedRepository.java

@@ -19,11 +19,12 @@ import io.moquette.broker.subscriptions.Topic;
 import io.netty.handler.codec.mqtt.MqttPublishMessage;
 
 public interface IRetainedRepository {
+
     void cleanRetained(Topic topic);
 
     void retain(Topic topic, MqttPublishMessage msg);
 
-    boolean isEmtpy();
+    boolean isEmpty();
 
     MqttPublishMessage retainedOnTopic(String topic);
 }

broker/src/main/java/io/moquette/broker/MemoryRetainedRepository.java

@@ -39,7 +39,7 @@ final class MemoryRetainedRepository implements IRetainedRepository {
     }
 
     @Override
-    public boolean isEmtpy() {
+    public boolean isEmpty() {
         return storage.isEmpty();
     }
 

broker/src/main/java/io/moquette/broker/subscriptions/CTrieSubscriptionDirectory.java

@@ -79,11 +79,6 @@ public class CTrieSubscriptionDirectory implements ISubscriptionsDirectory {
         return Optional.of(inode.mainNode());
     }
 
-    @Override
-    public List<Subscription> matches(Topic topic) {
-        return new ArrayList<>(matchQosSharpening(topic));
-    }
-
     /**
      * Given a topic string return the clients subscriptions that matches it. Topic string can't
      * contain character # and + because they are reserved to listeners subscriptions, and not topic
@@ -113,7 +108,7 @@ public class CTrieSubscriptionDirectory implements ISubscriptionsDirectory {
         return new HashSet<>(subsGroupedByClient.values());
     }
 
-    Set<Subscription> recursiveMatch(Topic topic, INode inode) {
+    private Set<Subscription> recursiveMatch(Topic topic, INode inode) {
         CNode cnode = inode.mainNode();
         if (Token.MULTI.equals(cnode.token)) {
             return cnode.subscriptions;

broker/src/main/java/io/moquette/broker/subscriptions/ISubscriptionsDirectory.java

@@ -32,8 +32,6 @@ public interface ISubscriptionsDirectory {
 
     void removeSubscription(Topic topic, String clientID);
 
-    List<Subscription> matches(Topic topic);
-
     int size();
 
     String dumpTree();