Remove unnecessary sleep

rabbitmq · Oct 4, 2023 · c0960c9 · c0960c9
1 parent e38d078
commit c0960c9
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/pkg/stomp_client/publisher.go b/pkg/stomp_client/publisher.go
@@ -29,10 +29,6 @@ type StompPublisher struct {
 }
 
 func NewPublisher(cfg config.Config, id int) *StompPublisher {
-	// sleep random interval to avoid all publishers publishing at exactly the same time
-	s := rand.Intn(cfg.Publishers)
-	time.Sleep(time.Duration(s) * time.Millisecond)
-
 	conn, err := stomp.Dial("tcp", cfg.PublisherUri, opts...)
 	if err != nil {
 		log.Error("publisher connection failed", "protocol", "STOMP", "publisherId", id, "error", err.Error())