commit 31a8c292f9ea449f64021e441419122f5f99aa12
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:35:12 2019 +0000
tree 50d8d15f179026c8b43a601549633f0e7aded74d
parent fd82236f8e3c52e8c7519ba1687fdc2c00be51ab

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

Change-Id: Ib35c0465519719badb621795485e44dc31b30828

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;