diff --git a/cmd/bucket-replication.go b/cmd/bucket-replication.go
index 91566c6a2..fecf8c9e7 100644
--- a/cmd/bucket-replication.go
+++ b/cmd/bucket-replication.go
@@ -2171,7 +2171,7 @@ func (p *ReplicationPool) queueReplicaTask(ri ReplicateObjectInfo) {
 		h := xxh3.HashString(ri.Bucket + ri.Name)
 		select {
 		case <-p.ctx.Done():
-		case p.lrgworkers[h%LargeWorkerCount] <- ri:
+		case p.lrgworkers[h%uint64(len(p.lrgworkers))] <- ri:
 		default:
 			globalReplicationPool.queueMRFSave(ri.ToMRFEntry())
 			p.mu.RLock()