commit c344f3031fcfdcee426f48e3f54d7918d1caec1f
author serkant.uluderya <serkant.uluderya@netsia.com> Fri May 29 23:26:57 2020 -0700
committer serkant.uluderya <serkant.uluderya@netsia.com> Thu Jun 04 09:20:53 2020 -0700
tree 5cbd28fe3ef1b32b5f7f0e18e7be1784e33bdcbe
parent 3fb6f74e0605e213aa86dfb80bf365f05228a651

[VOL-3116] Read openolt adapter's topic name from command-line

Change-Id: I98a80d0608736033610886d29b82a84efe1698ee

VERSION

diff --git a/VERSION b/VERSION
index 79a6144..59aa62c 100644
--- a/VERSION
+++ b/VERSION
@@ -1 +1 @@
-2.4.4
+2.4.5

pyvoltha/adapters/kafka/adapter_proxy.py

diff --git a/pyvoltha/adapters/kafka/adapter_proxy.py b/pyvoltha/adapters/kafka/adapter_proxy.py
index 3e63433..fe14808 100644
--- a/pyvoltha/adapters/kafka/adapter_proxy.py
+++ b/pyvoltha/adapters/kafka/adapter_proxy.py
@@ -34,9 +34,9 @@
 
 class AdapterProxy(ContainerProxy):
 
-    def __init__(self, kafka_proxy, core_topic, my_listening_topic):
+    def __init__(self, kafka_proxy, adapter_topic, my_listening_topic):
         super(AdapterProxy, self).__init__(kafka_proxy,
-                                           core_topic,
+                                           adapter_topic,
                                            my_listening_topic)
 
     def _to_string(self, unicode_str):
@@ -88,7 +88,7 @@
             h = InterAdapterHeader()
             h.type = type
             h.from_topic = self._to_string(from_adapter)
-            h.to_topic = self._to_string(to_adapter)
+            h.to_topic = self.remote_topic
             h.to_device_id = self._to_string(to_device_id)
             h.proxy_device_id = self._to_string(proxy_device_id)