diff --git a/broker/src/test/java/io/moquette/spi/persistence/MemorySessionStore.java b/broker/src/test/java/io/moquette/spi/persistence/MemorySessionStore.java index cd2ca20a..7934f8ce 100644 --- a/broker/src/test/java/io/moquette/spi/persistence/MemorySessionStore.java +++ b/broker/src/test/java/io/moquette/spi/persistence/MemorySessionStore.java @@ -40,7 +40,7 @@ public class MemorySessionStore implements ISessionsStore { private static final Logger LOG = LoggerFactory.getLogger(MemorySessionStore.class); - private Map> m_persistentSubscriptions = new HashMap<>(); + private Map> m_persistentSubscriptions = new HashMap<>(); private Map m_persistentSessions = new HashMap<>(); @@ -66,7 +66,7 @@ public class MemorySessionStore implements ISessionsStore { if (!m_persistentSubscriptions.containsKey(clientID)) { return; } - HashMap clientSubscriptions = m_persistentSubscriptions.get(clientID); + Map clientSubscriptions = m_persistentSubscriptions.get(clientID); clientSubscriptions.remove(topic); } @@ -135,7 +135,7 @@ public class MemorySessionStore implements ISessionsStore { @Override public List listAllSubscriptions() { List allSubscriptions = new ArrayList<>(); - for (Map.Entry> entry : m_persistentSubscriptions.entrySet()) { + for (Map.Entry> entry : m_persistentSubscriptions.entrySet()) { for (Subscription sub : entry.getValue().values()) { allSubscriptions.add(sub.asClientTopicCouple()); } @@ -145,7 +145,7 @@ public class MemorySessionStore implements ISessionsStore { @Override public Subscription getSubscription(ClientTopicCouple couple) { - HashMap subscriptions = m_persistentSubscriptions.get(couple.clientID); + Map subscriptions = m_persistentSubscriptions.get(couple.clientID); if (subscriptions == null || subscriptions.isEmpty()) { return null; } @@ -155,7 +155,7 @@ public class MemorySessionStore implements ISessionsStore { @Override public List getSubscriptions() { List subscriptions = new ArrayList<>(); - for (Map.Entry> entry : m_persistentSubscriptions.entrySet()) { + for (Map.Entry> entry : m_persistentSubscriptions.entrySet()) { subscriptions.addAll(entry.getValue().values()); } return subscriptions;