diff --git a/supervisor.go b/supervisor.go index d9c13c2..5081b6f 100644 --- a/supervisor.go +++ b/supervisor.go @@ -192,7 +192,7 @@ func StartSupervisor(conf *config.Config) (Supervisor, error) { worker := Worker{ id: i, queue: make(chan Request, wqSize), - respq: make(chan SenderResponse, wqSize), + respq: make(chan SenderResponse, wqSize*100), wgrp: &sync.WaitGroup{}, sn: SenderNum, ac: ac,