#655 give a random index for NewSubscriptionLoadBalancer

apache · Dec 26, 2023 · daa9594 · daa9594
1 parent 2d3cdf7
commit daa9594
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/golang/loadBalancer.go b/golang/loadBalancer.go
@@ -21,6 +21,7 @@ import (
 	"fmt"
 	"sync"
 	"sync/atomic"
+	"math/rand"
 
 	"github.com/apache/rocketmq-clients/golang/v5/pkg/utils"
 	v2 "github.com/apache/rocketmq-clients/golang/v5/protocol/v2"
@@ -134,6 +135,7 @@ var _ = SubscriptionLoadBalancer(&subscriptionLoadBalancer{})
 var NewSubscriptionLoadBalancer = func(messageQueues []*v2.MessageQueue) (SubscriptionLoadBalancer, error) {
 	slb := &subscriptionLoadBalancer{
 		messageQueues: messageQueues,
+		index: rand.Int31()
 	}
 	return slb, nil
 }