VOL-2180 code changes for context addition
Integrating InterContainerProxy interface changes
Change-Id: Ia20c5ac3093b7845acf80cce801ec0c1d90c125f
diff --git a/main_test.go b/main_test.go
index 84e2981..13f760c 100644
--- a/main_test.go
+++ b/main_test.go
@@ -156,7 +156,7 @@
ad := newMockAdapter()
- kip, _ := kafka.NewInterContainerProxy(
+ kip := kafka.NewInterContainerProxy(
kafka.InterContainerHost(ad.config.KafkaAdapterHost),
kafka.InterContainerPort(ad.config.KafkaAdapterPort),
kafka.MsgClient(&mockKafkaClient{}),
@@ -228,3 +228,7 @@
func (kc *mockKafkaClient) EnableHealthinessChannel(enable bool) chan bool {
return nil
}
+
+func (kc *mockKafkaClient) SubscribeForMetadata(func(fromTopic string, timestamp int64)) {
+ return
+}