Minor, fixed a shutdown exception

This commit is contained in:
andsel
2015-09-23 12:22:00 +02:00
parent 33bc23b4e1
commit ca99a00ac2
@@ -86,7 +86,7 @@ public class MapDBPersistentStore implements IMessagesStore, ISessionsStore {
LOG.error(null, ex);
throw new MQTTException("Can't create temp file for subscriptions storage [" + m_storePath + "]", ex);
}
m_db = DBMaker.newFileDB(tmpFile).closeOnJvmShutdown().make();
m_db = DBMaker.newFileDB(tmpFile).make();
}
m_retainedStore = m_db.getHashMap("retained");
m_persistentMessageStore = m_db.getHashMap("persistedMessages");