From 121fa6b1a25f0b3acdda8122362d6880c04b0a3d Mon Sep 17 00:00:00 2001 From: elinuxhenrik Date: Mon, 25 Oct 2021 08:06:25 +0200 Subject: [PATCH] Fix test of DMaaP Mediator Producer Issue-ID: NONRTRIC-612 Signed-off-by: elinuxhenrik Change-Id: Ib94010a9be3a6b2e85f6627cb19265177725f9dc --- dmaap-mediator-producer/internal/jobs/jobs_test.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/dmaap-mediator-producer/internal/jobs/jobs_test.go b/dmaap-mediator-producer/internal/jobs/jobs_test.go index 9fe27c3e..8533719e 100644 --- a/dmaap-mediator-producer/internal/jobs/jobs_test.go +++ b/dmaap-mediator-producer/internal/jobs/jobs_test.go @@ -165,6 +165,7 @@ func TestDeleteJob(t *testing.T) { func TestPollAndDistributeMessages(t *testing.T) { assertions := require.New(t) + wg := sync.WaitGroup{} messages := `[{"message": {"data": "data"}}]` pollClientMock := NewTestClient(func(req *http.Request) *http.Response { if req.URL.String() == "http://mrAddr/topicUrl" { @@ -196,7 +197,9 @@ func TestPollAndDistributeMessages(t *testing.T) { t.Fail() return nil }) + handlerUnderTest := NewJobHandlerImpl("", pollClientMock, distributeClientMock) + jobInfo := JobInfo{ InfoTypeIdentity: "type1", InfoJobIdentity: "job1", @@ -211,7 +214,6 @@ func TestPollAndDistributeMessages(t *testing.T) { handlerUnderTest.clearAll() }) - wg := sync.WaitGroup{} wg.Add(2) // Two calls should be made to the server, one to poll and one to distribute handlerUnderTest.pollAndDistributeMessages("http://mrAddr") -- 2.16.6