remove t.Fatal calls from non test goroutines

Before this commit, running `go vet ./...` would return:
```
pkg/queue/queue_test.go:50:6: call to (*T).Fatal from a non-test goroutine
pkg/queue/queue_test.go:94:6: call to (*T).Fatal from a non-test goroutine
```

Signed-off-by: Sanskar Jaiswal <jaiswalsanskar078@gmail.com>

Author: aryan9600

pkg/queue/queue_test.go

@@ -38,7 +38,11 @@ func TestSimpleSyncQueue_Basic(t *testing.T) {
 	numConsumers := 5
 	consumersWG := sync.WaitGroup{}
 	consumersWG.Add(numConsumers)
+	var fatal bool
 	for i := 0; i < numConsumers; i++ {
+		if fatal {
+			break
+		}
 		go func(i int) {
 			defer consumersWG.Done()
 			for {
@@ -47,14 +51,19 @@ func TestSimpleSyncQueue_Basic(t *testing.T) {
 					return
 				}
 				if !strings.HasPrefix(item.(string), "ns1/vm") {
-					t.Fatal("received item from queue after shutdown")
+					fatal = true
+					return
 				}
 				atomic.AddInt32(&countConsumed, 1)
 				time.Sleep(3 * time.Millisecond)
 			}
 		}(i)
 	}
 
+	if fatal {
+		t.Fatal("received item from queue after shutdown")
+	}
+
 	producersWG.Wait()
 	t.Log("shutting queue down")
 	q.Shutdown()
@@ -82,7 +91,11 @@ func TestSimpleSyncQueue_Duplicate(t *testing.T) {
 	numConsumers := 5
 	consumersWG := sync.WaitGroup{}
 	consumersWG.Add(numConsumers)
+	var fatal bool
 	for i := 0; i < numConsumers; i++ {
+		if fatal {
+			break
+		}
 		go func(i int) {
 			defer consumersWG.Done()
 			for {
@@ -91,14 +104,19 @@ func TestSimpleSyncQueue_Duplicate(t *testing.T) {
 					return
 				}
 				if !strings.HasPrefix(item.(string), "ns1/vm") {
-					t.Fatal("received item from queue after shutdown")
+					fatal = true
+					return
 				}
 				atomic.AddInt32(&countConsumed, 1)
 				time.Sleep(3 * time.Millisecond)
 			}
 		}(i)
 	}
 
+	if fatal {
+		t.Fatal("received item from queue after shutdown")
+	}
+
 	t.Log("shutting queue down")
 	q.Shutdown()
 	t.Log("enqueing message after shutdown")