diff --git a/nsq_probe_events_to_elasticsearch/nsq_probe_events_to_elasticsearch.go b/nsq_probe_events_to_elasticsearch/nsq_probe_events_to_elasticsearch.go
index <HASH>..<HASH> 100644
--- a/nsq_probe_events_to_elasticsearch/nsq_probe_events_to_elasticsearch.go
+++ b/nsq_probe_events_to_elasticsearch/nsq_probe_events_to_elasticsearch.go
@@ -160,7 +160,7 @@ func (q *InProgressMessageQueue) loop() {
 func NewInProgressMessageQueue() *InProgressMessageQueue {
 	q := &InProgressMessageQueue{
 		inProgress: make(map[string]*inProgressMessage),
-		status:     make(chan *eventdef.BulkSaveStatus, 10),
+		status:     make(chan *eventdef.BulkSaveStatus, *maxInFlight),
 	}
 	for i := 0; i < *concurrency; i++ {
 		go q.loop()
set the inprogress status queue (chan) to maxInflight