WIP

rabbitmq · Nov 22, 2024 · df4bb33 · df4bb33
1 parent 580fdee
commit df4bb33
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/cmd/root.go b/cmd/root.go
@@ -6,6 +6,7 @@ import (
 	"math"
 	"os"
 	"os/signal"
+	"sort"
 	"strconv"
 	"strings"
 	"sync"
@@ -397,16 +398,17 @@ func join_cluster(expectedInstance int, serviceName string) {
 	for i, node := range endpoints.Subsets[0].Addresses {
 		ips[i] = node.IP
 	}
+	ips = sort.StringSlice(ips)
 
-	log.Debug("IPs found", ips)
+	log.Debug("IPs found", "all", ips, "selected", ips[0])
 	list, err := memberlist.Create(memberlist.DefaultLANConfig())
 	if err != nil {
 		panic("Failed to create memberlist: " + err.Error())
 	}
 
 	// join the cluster
 	for {
-		_, err = list.Join(ips)
+		_, err = list.Join([]string{ips[0]})
 		if err == nil {
 			break
 		}