Use same retry delay as .NET stream client

lukebakken · lukebakken · commit bbb7210e2d9a · 2025-11-21T14:55:54.000-08:00
diff --git a/pkg/stream/environment.go b/pkg/stream/environment.go
@@ -573,7 +573,7 @@ func (cc *environmentCoordinator) newProducer(leader *Broker, tcpParameters *TCP
 		if err != nil {
 			return nil, err
 		}
-		time.Sleep(1 * time.Second)
+		time.Sleep(time.Duration(500+rand.Intn(1000)) * time.Millisecond)
 	}
 
 	producer, err := clientResult.declarePublisher(streamName, options, cleanUp)
@@ -632,7 +632,7 @@ func (cc *environmentCoordinator) newConsumer(connectionName string, leader *Bro
 		if err != nil {
 			return nil, err
 		}
-		time.Sleep(1 * time.Second)
+		time.Sleep(time.Duration(500+rand.Intn(1000)) * time.Millisecond)
 	}
 
 	subscriber, err := clientResult.declareSubscriber(streamName, messagesHandler, options, cleanUp)

Original file line number	Diff line number	Diff line change
`@@ -573,7 +573,7 @@ func (cc environmentCoordinator) newProducer(leader Broker, tcpParameters *TCP`
`573`	`573`	`if err != nil {`
`574`	`574`	`return nil, err`
`575`	`575`	`}`
`576`		`- time.Sleep(1 * time.Second)`
	`576`	`+ time.Sleep(time.Duration(500+rand.Intn(1000)) * time.Millisecond)`
`577`	`577`	`}`
`578`	`578`
`579`	`579`	`producer, err := clientResult.declarePublisher(streamName, options, cleanUp)`
`@@ -632,7 +632,7 @@ func (cc environmentCoordinator) newConsumer(connectionName string, leader Bro`
`632`	`632`	`if err != nil {`
`633`	`633`	`return nil, err`
`634`	`634`	`}`
`635`		`- time.Sleep(1 * time.Second)`
	`635`	`+ time.Sleep(time.Duration(500+rand.Intn(1000)) * time.Millisecond)`
`636`	`636`	`}`
`637`	`637`
`638`	`638`	`subscriber, err := clientResult.declareSubscriber(streamName, messagesHandler, options, cleanUp)`