diff --git a/cmd/mesh-controller/moved_bus_test.go b/cmd/mesh-controller/moved_bus_test.go index ebf93d7e..c793ba96 100644 --- a/cmd/mesh-controller/moved_bus_test.go +++ b/cmd/mesh-controller/moved_bus_test.go @@ -75,6 +75,10 @@ func TestAModuleBuiltFromANewRepositoryIsRegisteredOnlyOnTheOperatorsApproveOnTh if err := server.KeepsDeliveryMerges(keepingDeliveryMerges{js: server.JetStream}); err != nil { t.Fatal(err) } + // The events consumer exists, from now on, before the word is published: Receive would make it too late. + if err := broker.AssertServingConsumers(js); err != nil { + t.Fatal(err) + } serving, stop := context.WithCancel(context.Background()) done := make(chan struct{}) go func() { defer close(done); _ = server.Serve(serving) }()