commit 2bfa94cf1564d84dea493285decf9f554494e9c8
author Madan Jampani <madan@onlab.us> Sat Apr 11 05:03:49 2015 -0700
committer Gerrit Code Review <gerrit@onlab.us> Mon Apr 13 16:51:24 2015 +0000
tree 71d41994e021ccca6037423e2cef99b18d81bb07
parent 0feedc02601e726ed3aeb8e4b250c43569ce9568

Revamped ClusterCommunicationService API

Change-Id: I9326369de3d2413b0882b324979d10483c093de9

apps/test/intent-perf/src/main/java/org/onosproject/intentperf/IntentPerfInstaller.java

diff --git a/apps/test/intent-perf/src/main/java/org/onosproject/intentperf/IntentPerfInstaller.java b/apps/test/intent-perf/src/main/java/org/onosproject/intentperf/IntentPerfInstaller.java
index 909f3a5..de9e9f2 100644
--- a/apps/test/intent-perf/src/main/java/org/onosproject/intentperf/IntentPerfInstaller.java
+++ b/apps/test/intent-perf/src/main/java/org/onosproject/intentperf/IntentPerfInstaller.java
@@ -249,14 +249,14 @@
     public void start() {
         if (stopped) {
             stopped = false;
-            communicationService.broadcast(new ClusterMessage(nodeId, CONTROL, START.getBytes()));
+            communicationService.broadcast(START, CONTROL, str -> str.getBytes());
             startTestRun();
         }
     }
 
     public void stop() {
         if (!stopped) {
-            communicationService.broadcast(new ClusterMessage(nodeId, CONTROL, STOP.getBytes()));
+            communicationService.broadcast(STOP, CONTROL, str -> str.getBytes());
             stopTestRun();
         }
     }