commit e7b1bd22764a16fd880258490e75c0374c59bbfa
author Jian Li <pyguni@gmail.com> Wed Jun 27 15:15:28 2018 +0900
committer Jian Li <pyguni@gmail.com> Wed Jun 27 15:15:28 2018 +0900
tree bd7debb2b9e1994428d2b2334855708a21af8c6b
parent 4b931a988e2f6b547769ba70c815aaea4fe6b5d0

Fix: correctly generate kafka message from openstack telemetry

Change-Id: Id608ef0a3dd7f18e35fc59473ee6b7ef8077ac39

apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java

diff --git a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java
index 3b849d1..228bc2b 100644
--- a/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java
+++ b/apps/openstacktelemetry/app/src/main/java/org/onosproject/openstacktelemetry/codec/TinaMessageByteBufferCodec.java
@@ -60,7 +60,7 @@
         ByteBuffer byteBuffer = ByteBuffer.allocate(flowInfos.size() * ENTRY_SIZE);
 
         TinaFlowInfoByteBufferCodec codec = new TinaFlowInfoByteBufferCodec();
-        flowInfos.forEach(flowInfo -> byteBuffer.put(codec.encode(flowInfo)));
+        flowInfos.forEach(flowInfo -> byteBuffer.put(codec.encode(flowInfo).array()));
 
         return byteBuffer.array();
     }