Update the device discovery protos to include the core POD name.
Change-Id: I0d562487f5ea5ba5e5ccfbb89d276a254edc612c
diff --git a/tests/kafka/kafka_inter_container_messaging_test.go b/tests/kafka/kafka_inter_container_messaging_test.go
index 57e7ab9..de97558 100644
--- a/tests/kafka/kafka_inter_container_messaging_test.go
+++ b/tests/kafka/kafka_inter_container_messaging_test.go
@@ -524,7 +524,7 @@
time.Sleep(time.Millisecond * 100)
// Send the message
- go testProxy.DeviceDiscovered("TestDeviceId", "TestDevicetype", "TestParentId")
+ go testProxy.DeviceDiscovered("TestDeviceId", "TestDevicetype", "TestParentId", "myPODName")
msg := <-waitingChannel
totalTime := (time.Now().UnixNano() - msg.Header.Timestamp) / int64(time.Millisecond)
@@ -536,6 +536,7 @@
assert.Equal(t, dd.Id, "TestDeviceId")
assert.Equal(t, dd.DeviceType, "TestDevicetype")
assert.Equal(t, dd.ParentId, "TestParentId")
+ assert.Equal(t, dd.Publisher, "myPODName")
log.Debugw("TotalTime", log.Fields{"time": totalTime})
}