[VOL-1034] This commit consists of:
1) Implement PM collections from the ONU
2) Update the Registration method to include for the adapter type
and its supported device types.
Change-Id: Id984468546328b6ebf2ca47578675c69b2b66f01
diff --git a/adapters/kafka/core_proxy.py b/adapters/kafka/core_proxy.py
index 36459ed..cc3f081 100644
--- a/adapters/kafka/core_proxy.py
+++ b/adapters/kafka/core_proxy.py
@@ -38,10 +38,12 @@
@ContainerProxy.wrap_request(CoreInstance)
@inlineCallbacks
- def register(self, adapter):
+ def register(self, adapter, deviceTypes):
log.debug("register")
try:
- res = yield self.invoke(rpc="Register", adapter=adapter)
+ res = yield self.invoke(rpc="Register",
+ adapter=adapter,
+ deviceTypes=deviceTypes)
log.info("registration-returned", res=res)
returnValue(res)
except Exception as e: