issue 1025: the bus test makes the controller's consumers before it publishes mesh-delivery's word

2026-10-17 17:18:56 +02:00
parent 43b59c5dff
commit e42becb479
1 changed files with 4 additions and 0 deletions
@@ -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) }()