[VOL-4290] Voltha go library updates for gRPC migration
Change-Id: I1aa2774beb6b7ed7419bc45aeb53fcae8a8ecda0
diff --git a/pkg/mocks/kafka/kafka_client_test.go b/pkg/mocks/kafka/kafka_client_test.go
index edd531e..cc3a779 100644
--- a/pkg/mocks/kafka/kafka_client_test.go
+++ b/pkg/mocks/kafka/kafka_client_test.go
@@ -18,11 +18,12 @@
import (
"context"
- "github.com/opencord/voltha-lib-go/v6/pkg/kafka"
- ic "github.com/opencord/voltha-protos/v4/go/inter_container"
- "github.com/stretchr/testify/assert"
"testing"
"time"
+
+ "github.com/opencord/voltha-lib-go/v7/pkg/kafka"
+ ic "github.com/opencord/voltha-protos/v5/go/inter_container"
+ "github.com/stretchr/testify/assert"
)
func TestKafkaClientCreateTopic(t *testing.T) {
@@ -50,9 +51,9 @@
assert.NotNil(t, ch)
testCh := make(chan bool)
maxWait := 5 * time.Millisecond
- msg := &ic.InterContainerMessage{
- Header: &ic.Header{Id: "1234", ToTopic: topic.Name},
- Body: nil,
+ msg := &ic.DeviceReason{
+ DeviceId: "1234",
+ Reason: "mock",
}
timer := time.NewTimer(maxWait)
defer timer.Stop()