commit 175e8fde54342d3f9440134bf06a1c2ffcb99acc
author Madan Jampani <madan@onlab.us> Wed May 20 14:10:45 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Thu May 21 22:36:34 2015 +0000
tree 58074b9e62e657a55b2ca6c00055c5dbdaea9050
parent fb446fe074da879366dda9cdae53bcd199b7ad7e

Removed deprecated ClusterCommunicationService APIs
MessagingService::sendAsync now returns a CompletableFuture<Void> in place of boolean

Change-Id: I98134c4c0ea65b9c7e9ba705eebd1669067324ef

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 1b41d0c..77db68c 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
@@ -18,7 +18,6 @@
 import com.google.common.collect.ComparisonChain;
 import com.google.common.collect.ImmutableSet;
 import com.google.common.collect.Lists;
-import com.google.common.util.concurrent.ListenableFuture;
 import com.google.common.util.concurrent.MoreExecutors;
 
 import org.junit.After;
@@ -145,7 +144,7 @@
                 .register(KryoNamespaces.API)
                 .register(TestTimestamp.class);
 
-        ecMap = new EventuallyConsistentMapBuilderImpl<>(
+        ecMap = new EventuallyConsistentMapBuilderImpl<String, String>(
                         clusterService, clusterCommunicator)
                 .withName(MAP_NAME)
                 .withSerializer(serializer)
@@ -702,7 +701,7 @@
                     anyObject(MessageSubject.class),
                     anyObject(Function.class),
                     anyObject(NodeId.class)))
-                .andReturn(true)
+                .andReturn(CompletableFuture.completedFuture(null))
                 .anyTimes();
         replay(clusterCommunicator);
     }
@@ -761,9 +760,9 @@
         }
 
         @Override
-        public <M> boolean unicast(M message, MessageSubject subject,
+        public <M> CompletableFuture<Void> unicast(M message, MessageSubject subject,
                 Function<M, byte[]> encoder, NodeId toNodeId) {
-            return false;
+            return null;
         }
 
         @Override
@@ -795,33 +794,6 @@
                 Function<byte[], M> decoder, Consumer<M> handler,
                 Executor executor) {
         }
-
-        @Override
-        public boolean broadcast(ClusterMessage message) {
-            return false;
-        }
-
-        @Override
-        public boolean broadcastIncludeSelf(ClusterMessage message) {
-            return false;
-        }
-
-        @Override
-        public boolean unicast(ClusterMessage message, NodeId toNodeId) {
-            return false;
-        }
-
-        @Override
-        public boolean multicast(ClusterMessage message,
-                Iterable<NodeId> nodeIds) {
-            return false;
-        }
-
-        @Override
-        public ListenableFuture<byte[]> sendAndReceive(ClusterMessage message,
-                NodeId toNodeId) {
-            return null;
-        }
     }
 
     /**