commit 3d27ae5936cdd1a466ea3893a2d544ac5ca276c4
author Pravin Chaudhary <pravin.chaudhary@taranawireless.com> Thu Jan 03 17:43:15 2019 +0530
committer Andrea Campanella <andrea@opennetworking.org> Wed Jan 09 08:38:42 2019 +0000
tree 51b9df752422f3a83ea9fd5e400a2ce95c3251d9
parent bcc1762c887f22ba8db8d2021fbee84720935d4c

Fix: ONOS-7878. Serialized Device Annotations so that Events published to Kakfa carry the annotations.

Change-Id: Ib35c0465519719badb621795485e44dc31b30828
(cherry picked from commit 31a8c292f9ea449f64021e441419122f5f99aa12)

apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/converter/DeviceEventConverter.java

diff --git a/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/converter/DeviceEventConverter.java b/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/converter/DeviceEventConverter.java
index a445b14..ecc54eb 100644
--- a/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/converter/DeviceEventConverter.java
+++ b/apps/kafka-integration/app/src/main/java/org/onosproject/kafkaintegration/converter/DeviceEventConverter.java
@@ -24,6 +24,7 @@
 import org.onosproject.grpc.net.device.models.PortEnumsProto;
 import org.onosproject.grpc.net.models.DeviceProtoOuterClass.DeviceProto;
 import org.onosproject.grpc.net.models.PortProtoOuterClass;
+import org.onosproject.incubator.protobuf.models.net.AnnotationsTranslator;
 import org.onosproject.net.device.DeviceEvent;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -81,6 +82,7 @@
                         .setSwVersion(deviceEvent.subject().swVersion())
                         .setType(DeviceTypeProto
                                          .valueOf(deviceEvent.subject().type().name()))
+                        .putAllAnnotations(AnnotationsTranslator.asMap(deviceEvent.subject().annotations()))
                         .build();
 
         PortProtoOuterClass.PortProto portProto = null;