this is just an smoke test for consumefromqueue function to see if it…

… stops when a context cancel gets there
knative-extensions · Jul 27, 2023 · 2c761bb · 2c761bb
1 parent 4b38a8f
commit 2c761bb
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/pkg/dispatcher/dispatcher_test.go b/pkg/dispatcher/dispatcher_test.go
@@ -60,10 +60,7 @@ func TestDispatcher_ConsumeFromQueue(t *testing.T) {
 		time.Sleep(1000)
 		cancelFunc()
 	}()
-
-	if err := d.ConsumeFromQueue(ctx, &rabbit.RabbitMQConnectionMock{}, &rabbit.RabbitMQChannelMock{}, ""); err != nil {
-		t.Errorf("ConsumeFromQueue() error = %v", err)
-	}
+	d.ConsumeFromQueue(ctx, &rabbit.RabbitMQConnectionMock{}, &rabbit.RabbitMQChannelMock{}, "")
 }
 
 func TestDispatcher_ReadSpan(t *testing.T) {