commit 2b8e189ea525f507dbe6693641b90a16fd433118
author Madan Jampani <madan.jampani@gmail.com> Fri Dec 04 11:16:47 2015 -0800
committer Gerrit Code Review <gerrit@onlab.us> Fri Dec 04 19:33:24 2015 +0000
tree 66c67f20c017bab23334769c5a0a5e78ef5779ec
parent 4fe18c8f0cde7a23830b6b1891abbb46995924d8

Added an adapter for PersistenceService to be used in unit tests

Change-Id: Ided127f848b97632b021ea1f1c88d912fe28492c

core/store/dist/src/test/java/org/onosproject/store/ecmap/EventuallyConsistentMapImplTest.java

diff --git a/core/store/dist/src/test/java/org/onosproject/store/ecmap/EventuallyConsistentMapImplTest.java b/core/store/dist/src/test/java/org/onosproject/store/ecmap/EventuallyConsistentMapImplTest.java
index ef8d992..b74aa37 100644
--- a/core/store/dist/src/test/java/org/onosproject/store/ecmap/EventuallyConsistentMapImplTest.java
+++ b/core/store/dist/src/test/java/org/onosproject/store/ecmap/EventuallyConsistentMapImplTest.java
@@ -42,12 +42,13 @@
 import org.onosproject.cluster.DefaultControllerNode;
 import org.onosproject.cluster.NodeId;
 import org.onosproject.event.AbstractEvent;
-import org.onosproject.persistence.impl.PersistenceManager;
+import org.onosproject.persistence.PersistenceService;
 import org.onosproject.store.Timestamp;
 import org.onosproject.store.cluster.messaging.ClusterCommunicationService;
 import org.onosproject.store.cluster.messaging.ClusterCommunicationServiceAdapter;
 import org.onosproject.store.cluster.messaging.MessageSubject;
 import org.onosproject.store.impl.LogicalTimestamp;
+import org.onosproject.store.persistence.TestPersistenceService;
 import org.onosproject.store.serializers.KryoNamespaces;
 import org.onosproject.store.serializers.KryoSerializer;
 import org.onosproject.store.service.EventuallyConsistentMap;
@@ -82,7 +83,7 @@
 
     private EventuallyConsistentMap<String, String> ecMap;
 
-    private PersistenceManager persistenceService;
+    private PersistenceService persistenceService;
     private ClusterService clusterService;
     private ClusterCommunicationService clusterCommunicator;
     private SequentialClockService<String, String> clockService;
@@ -138,8 +139,7 @@
 
         clusterCommunicator = createMock(ClusterCommunicationService.class);
 
-        persistenceService = new PersistenceManager();
-        persistenceService.activate();
+        persistenceService = new TestPersistenceService();
         // Add expectation for adding cluster message subscribers which
         // delegate to our ClusterCommunicationService implementation. This
         // allows us to get a reference to the map's internal cluster message