X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Finternal%2Fjobs%2Fjobs_test.go;h=8533719ee3fb05f52b70b2b562fcc8bd8411f7de;hb=cc74808f1f5835a0b42c77ced5a585648d6d434c;hp=b301c2f80e1add35a366b4f275d7f6ee88733d35;hpb=4bbbfe8d82d08054a9baacdc63f117eb1dd24524;p=nonrtric.git

diff --git a/dmaap-mediator-producer/internal/jobs/jobs_test.go b/dmaap-mediator-producer/internal/jobs/jobs_test.go
index b301c2f8..8533719e 100644
--- a/dmaap-mediator-producer/internal/jobs/jobs_test.go
+++ b/dmaap-mediator-producer/internal/jobs/jobs_test.go
@@ -31,6 +31,7 @@ import (
 	"time"
 
 	"github.com/stretchr/testify/require"
+	"oransc.org/nonrtric/dmaapmediatorproducer/internal/config"
 )
 
 const typeDefinition = `{"types": [{"id": "type1", "dmaapTopicUrl": "events/unauthenticated.SEC_FAULT_OUTPUT/dmaapmediatorproducer/type1"}]}`
@@ -51,11 +52,11 @@ func TestGetTypes_filesOkShouldReturnSliceOfTypesAndProvideSupportedTypes(t *tes
 		t.Errorf("Unable to create temporary config file for types due to: %v", err)
 	}
 	types, err := handlerUnderTest.GetTypes()
-	wantedType := TypeDefinition{
+	wantedType := config.TypeDefinition{
 		Id:            "type1",
 		DmaapTopicURL: "events/unauthenticated.SEC_FAULT_OUTPUT/dmaapmediatorproducer/type1",
 	}
-	wantedTypes := []TypeDefinition{wantedType}
+	wantedTypes := []config.TypeDefinition{wantedType}
 	assertions.EqualValues(wantedTypes, types)
 	assertions.Nil(err)
 
@@ -196,7 +197,9 @@ func TestPollAndDistributeMessages(t *testing.T) {
 		t.Fail()
 		return nil
 	})
+
 	handlerUnderTest := NewJobHandlerImpl("", pollClientMock, distributeClientMock)
+
 	jobInfo := JobInfo{
 		InfoTypeIdentity: "type1",
 		InfoJobIdentity:  "job1",