From 912a88ec0a13cceb159ae03db669a2608811cf2e Mon Sep 17 00:00:00 2001 From: andsel Date: Fri, 23 Sep 2016 12:10:42 +0200 Subject: [PATCH] Minor, switched from .replace to .put (JDK 1.7 compatibility) --- .../java/io/moquette/spi/persistence/MapDBMessagesStore.java | 4 ++-- .../test/java/io/moquette/spi/impl/MemoryMessagesStore.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/broker/src/main/java/io/moquette/spi/persistence/MapDBMessagesStore.java b/broker/src/main/java/io/moquette/spi/persistence/MapDBMessagesStore.java index 54668069..4eb497e0 100644 --- a/broker/src/main/java/io/moquette/spi/persistence/MapDBMessagesStore.java +++ b/broker/src/main/java/io/moquette/spi/persistence/MapDBMessagesStore.java @@ -130,13 +130,13 @@ class MapDBMessagesStore implements IMessagesStore { public void incUsageCounter(MessageGUID guid) { IMessagesStore.StoredMessage storedMessage = m_persistentMessageStore.get(guid); storedMessage.incReferenceCounter(); - m_persistentMessageStore.replace(guid, storedMessage); + m_persistentMessageStore.put(guid, storedMessage); } @Override public void decUsageCounter(MessageGUID guid) { IMessagesStore.StoredMessage storedMessage = m_persistentMessageStore.get(guid); storedMessage.decReferenceCounter(); - m_persistentMessageStore.replace(guid, storedMessage); + m_persistentMessageStore.put(guid, storedMessage); } } diff --git a/broker/src/test/java/io/moquette/spi/impl/MemoryMessagesStore.java b/broker/src/test/java/io/moquette/spi/impl/MemoryMessagesStore.java index 75af2e00..3cf8d5cb 100644 --- a/broker/src/test/java/io/moquette/spi/impl/MemoryMessagesStore.java +++ b/broker/src/test/java/io/moquette/spi/impl/MemoryMessagesStore.java @@ -112,13 +112,13 @@ public class MemoryMessagesStore implements IMessagesStore { public void incUsageCounter(MessageGUID guid) { IMessagesStore.StoredMessage storedMessage = m_persistentMessageStore.get(guid); storedMessage.incReferenceCounter(); - m_persistentMessageStore.replace(guid, storedMessage); + m_persistentMessageStore.put(guid, storedMessage); } @Override public void decUsageCounter(MessageGUID guid) { IMessagesStore.StoredMessage storedMessage = m_persistentMessageStore.get(guid); storedMessage.decReferenceCounter(); - m_persistentMessageStore.replace(guid, storedMessage); + m_persistentMessageStore.put(guid, storedMessage); } }