diff --git a/cmd/bucket-replication.go b/cmd/bucket-replication.go
index e0c96df01..dcd3262b9 100644
--- a/cmd/bucket-replication.go
+++ b/cmd/bucket-replication.go
@@ -310,7 +310,7 @@ func newReplicationState() *replicationState {
 		globalReplicationConcurrent = 1
 	}
 	rs := &replicationState{
-		replicaCh: make(chan ObjectInfo, globalReplicationConcurrent*2),
+		replicaCh: make(chan ObjectInfo, 10000),
 	}
 	go func() {
 		<-GlobalContext.Done()
@@ -332,6 +332,7 @@ func (r *replicationState) addWorker(ctx context.Context, objectAPI ObjectLayer)
 					return
 				}
 				replicateObject(ctx, oi, objectAPI)
+			default:
 			}
 		}
 	}()