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

Removed the reference counter for stored messages

Browse Source
This commit is contained in:
andsel
2017-01-09 21:59:09 +01:00
parent 081631242f
commit ac8a11fefa
4 changed files with 3 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/spi/persistence/MapDBMessagesStore.java
+1 -18
View File
@@ -101,10 +101,7 @@ class MapDBMessagesStore implements IMessagesStore {
void removeStoredMessage(MessageGUID guid) {
//remove only the not retained and no more referenced
StoredMessage storedMessage = m_persistentMessageStore.get(guid);
if (!storedMessage.isRetained() && storedMessage.getReferenceCounter() <= 0) {
if(storedMessage.getReferenceCounter() < 0) {
LOG.error("we should never have gotten a reference count less than zero");
}
if (!storedMessage.isRetained()) {
LOG.debug("Cleaning not retained message guid {}", guid);
m_persistentMessageStore.remove(guid);
}
@@ -119,18 +116,4 @@ class MapDBMessagesStore implements IMessagesStore {
public void cleanRetained(String topic) {
m_retainedStore.remove(topic);
}
@Override
public void incUsageCounter(MessageGUID guid) {
IMessagesStore.StoredMessage storedMessage = m_persistentMessageStore.get(guid);
storedMessage.incReferenceCounter();
m_persistentMessageStore.put(guid, storedMessage);
}
@Override
public void decUsageCounter(MessageGUID guid) {
IMessagesStore.StoredMessage storedMessage = m_persistentMessageStore.get(guid);
storedMessage.decReferenceCounter();
m_persistentMessageStore.put(guid, storedMessage);
}
}