anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Minor, switched from .replace to .put (JDK 1.7 compatibility)

Browse Source
This commit is contained in:
andsel
2016-09-23 12:10:42 +02:00
parent 8215e89d77
commit 912a88ec0a
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/spi/persistence/MapDBMessagesStore.java
+2 -2
View File
@@ -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);
}
}