diff options
Diffstat (limited to 'weed/mq/broker/broker_grpc_pub.go')
| -rw-r--r-- | weed/mq/broker/broker_grpc_pub.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/mq/broker/broker_grpc_pub.go b/weed/mq/broker/broker_grpc_pub.go index c7cb81fcc..cd072503c 100644 --- a/weed/mq/broker/broker_grpc_pub.go +++ b/weed/mq/broker/broker_grpc_pub.go @@ -4,7 +4,7 @@ import ( "context" "fmt" "io" - "math/rand" + "math/rand/v2" "net" "sync/atomic" "time" @@ -71,7 +71,7 @@ func (b *MessageQueueBroker) PublishMessage(stream mq_pb.SeaweedMessaging_Publis var isClosed bool // process each published messages - clientName := fmt.Sprintf("%v-%4d", findClientAddress(stream.Context()), rand.Intn(10000)) + clientName := fmt.Sprintf("%v-%4d", findClientAddress(stream.Context()), rand.IntN(10000)) publisher := topic.NewLocalPublisher() localTopicPartition.Publishers.AddPublisher(clientName, publisher) |