VOL-1536 Inter OpenOLT/Onu Adapter Messaging
1. Add GetDevice/GetChildDevice to facilitate ONU adapter look up ONU data in core
2. fix bug in sending proxy message
Change-Id: I1206430627408c9e6fcedc12d9e78d95eaa60ee5
diff --git a/adapters/common/adapter_proxy.go b/adapters/common/adapter_proxy.go
index 13b98b0..6c32422 100644
--- a/adapters/common/adapter_proxy.go
+++ b/adapters/common/adapter_proxy.go
@@ -86,9 +86,9 @@
}
// Set up the required rpc arguments
- topic := kafka.Topic{Name: fromAdapter}
- replyToTopic := kafka.Topic{Name: toAdapter}
- rpc := "Process_inter_adapter_message"
+ topic := kafka.Topic{Name: toAdapter}
+ replyToTopic := kafka.Topic{Name: fromAdapter}
+ rpc := "process_inter_adapter_message"
success, result := ap.kafkaICProxy.InvokeRPC(ctx, rpc, &topic, &replyToTopic, true, proxyDeviceId, args...)
log.Debugw("inter-adapter-msg-response", log.Fields{"replyTopic": replyToTopic, "success": success})