Minor change, just renamed method
This commit is contained in:
+1
-1
@@ -35,5 +35,5 @@ public interface IPersistentSubscriptionStore {
|
||||
*/
|
||||
void wipeSubscriptions(String sessionID);
|
||||
|
||||
List<Subscription> retrieveAllSubscriptions();
|
||||
List<Subscription> listAllSubscriptions();
|
||||
}
|
||||
|
||||
+1
-1
@@ -264,7 +264,7 @@ public class HawtDBStorageService implements IStorageService {
|
||||
m_persistentSubscriptions.remove(clientID);
|
||||
}
|
||||
|
||||
public List<Subscription> retrieveAllSubscriptions() {
|
||||
public List<Subscription> listAllSubscriptions() {
|
||||
List<Subscription> allSubscriptions = new ArrayList<Subscription>();
|
||||
for (Map.Entry<String, Set<Subscription>> entry : m_persistentSubscriptions) {
|
||||
allSubscriptions.addAll(entry.getValue());
|
||||
|
||||
+1
-1
@@ -134,7 +134,7 @@ public class MemoryStorageService implements IStorageService {
|
||||
m_persistentSubscriptions.remove(clientID);
|
||||
}
|
||||
|
||||
public List<Subscription> retrieveAllSubscriptions() {
|
||||
public List<Subscription> listAllSubscriptions() {
|
||||
List<Subscription> allSubscriptions = new ArrayList<Subscription>();
|
||||
for (Map.Entry<String, Set<Subscription>> entry : m_persistentSubscriptions.entrySet()) {
|
||||
allSubscriptions.addAll(entry.getValue());
|
||||
|
||||
@@ -203,7 +203,7 @@ public class SimpleMessaging implements IMessaging, EventHandler<ValueEvent> {
|
||||
private void processInit(Properties props) {
|
||||
m_storageService = new HawtDBStorageService();
|
||||
m_storageService.initStore();
|
||||
List<Subscription> storedSubscriptions = m_storageService.retrieveAllSubscriptions();
|
||||
List<Subscription> storedSubscriptions = m_storageService.listAllSubscriptions();
|
||||
subscriptions.init(storedSubscriptions);
|
||||
|
||||
String passwdPath = props.getProperty("password_file");
|
||||
|
||||
+1
-1
@@ -63,7 +63,7 @@ public class HawtDBStorageServiceTest {
|
||||
m_storageService.addNewSubscription(overrindingSubscription, overrindingSubscription.getClientId());
|
||||
|
||||
//Verify
|
||||
List<Subscription> subscriptions = m_storageService.retrieveAllSubscriptions();
|
||||
List<Subscription> subscriptions = m_storageService.listAllSubscriptions();
|
||||
assertEquals(1, subscriptions.size());
|
||||
Subscription sub = subscriptions.get(0);
|
||||
assertEquals(overrindingSubscription.getRequestedQos(), sub.getRequestedQos());
|
||||
|
||||
Reference in New Issue
Block a user