From e42becb479a475d25305889b5419a752d6af1d63 Mon Sep 17 00:00:00 2001 From: jochen Date: Sat, 17 Oct 2026 17:18:56 +0200 Subject: [PATCH] issue 1025: the bus test makes the controller's consumers before it publishes mesh-delivery's word --- cmd/mesh-controller/moved_bus_test.go | 4 ++++ 1 file changed, 4 insertions(+) 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) }()