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

Renamed DummyStorageService to MemoryStorageService

Browse Source
This commit is contained in:
andrea
2013-08-30 18:09:24 +02:00
parent 63333b11ad
commit 635d37112e
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/DummyStorageService.java → broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/MemoryStorageService.java
+2 -2
View File
@@ -19,7 +19,7 @@ import org.slf4j.LoggerFactory;
/**
*/
public class DummyStorageService implements IStorageService {
public class MemoryStorageService implements IStorageService {
private Map<String, Set<Subscription>> m_persistentSubscriptions = new HashMap<String, Set<Subscription>>();
private Map<String, HawtDBStorageService.StoredMessage> m_retainedStore = new HashMap<String, HawtDBStorageService.StoredMessage>();
@@ -27,7 +27,7 @@ public class DummyStorageService implements IStorageService {
private Map<String, PublishEvent> m_inflightStore = new HashMap<String, PublishEvent>();
private Map<String, PublishEvent> m_qos2Store = new HashMap<String, PublishEvent>();
private static final Logger LOG = LoggerFactory.getLogger(DummyStorageService.class);
private static final Logger LOG = LoggerFactory.getLogger(MemoryStorageService.class);
public void initStore() {
//To change body of implemented methods use File | Settings | File Templates.
broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/ProtocolProcessorTest.java
+2 -2
View File
@@ -74,7 +74,7 @@ public class ProtocolProcessorTest {
//sleep to let the messaging batch processor to process the initEvent
Thread.sleep(300);
m_storageService = new DummyStorageService();
m_storageService = new MemoryStorageService();
//m_storageService.initStore();
subscriptions = new SubscriptionsStore();
@@ -231,7 +231,7 @@ public class ProtocolProcessorTest {
}
}
};
subs.init(new DummyStorageService());
subs.init(new MemoryStorageService());
//simulate a connect that register a clientID to an IoSession
IMessaging mockedMessaging = mock(IMessaging.class);
broker/src/test/java/org/dna/mqtt/moquette/messaging/spi/impl/subscriptions/SubscriptionsStoreTest.java
+2 -2
View File
@@ -6,7 +6,7 @@ import java.text.ParseException;
import java.util.Arrays;
import java.util.List;
import org.dna.mqtt.moquette.messaging.spi.impl.DummyStorageService;
import org.dna.mqtt.moquette.messaging.spi.impl.MemoryStorageService;
import org.dna.mqtt.moquette.proto.messages.AbstractMessage;
import org.fusesource.hawtdb.api.MultiIndexFactory;
import org.fusesource.hawtdb.api.PageFile;
@@ -40,7 +40,7 @@ public class SubscriptionsStoreTest {
pageFactory.open();
PageFile pageFile = pageFactory.getPageFile();
MultiIndexFactory multiIndexFactory = new MultiIndexFactory(pageFile);
store.init(new DummyStorageService());
store.init(new MemoryStorageService());
}
@After