X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=dmaap-mediator-producer%2Finternal%2Fjobs%2Fjobs_test.go;h=6f2922724d04f4b1d70ecf60d54d656b6d6c779a;hb=fe61c6191ba72b1d8297264c3d61566ea23a70b6;hp=3bb25787890ab46c14a69072784195898f13d451;hpb=382870d3056e724f1e587ab21cd25411bceaaac7;p=nonrtric.git

diff --git a/dmaap-mediator-producer/internal/jobs/jobs_test.go b/dmaap-mediator-producer/internal/jobs/jobs_test.go
index 3bb25787..6f292272 100644
--- a/dmaap-mediator-producer/internal/jobs/jobs_test.go
+++ b/dmaap-mediator-producer/internal/jobs/jobs_test.go
@@ -132,6 +132,30 @@ func TestAddJobWhenTargetUriMissing_shouldReturnError(t *testing.T) {
 	assertions.Equal("missing required target URI: {  job1  <nil> type1}", err.Error())
 	clearAll()
 }
+
+func TestDeleteJob(t *testing.T) {
+	assertions := require.New(t)
+	jobToKeep := JobInfo{
+		InfoJobIdentity:  "job1",
+		InfoTypeIdentity: "type1",
+	}
+	jobToDelete := JobInfo{
+		InfoJobIdentity:  "job2",
+		InfoTypeIdentity: "type1",
+	}
+	allTypes["type1"] = TypeData{
+		TypeId: "type1",
+		Jobs:   map[string]JobInfo{"job1": jobToKeep, "job2": jobToDelete},
+	}
+	t.Cleanup(func() {
+		clearAll()
+	})
+
+	DeleteJob("job2")
+	assertions.Equal(1, len(allTypes["type1"].Jobs))
+	assertions.Equal(jobToKeep, allTypes["type1"].Jobs["job1"])
+}
+
 func TestPollAndDistributeMessages(t *testing.T) {
 	assertions := require.New(t)
 	jobInfo := JobInfo{