Shorter timeout

downloader/main.go

@@ -35,7 +35,7 @@ func init() {
 		log.Lmicroseconds|log.Lshortfile)
 }
 
-const DOWNLOAD_WORKERS = 1
+const DOWNLOAD_WORKERS = 2
 
 type DLHandler struct{}
 
@@ -52,7 +52,7 @@ func (*DLHandler) HandleMessage(message *nsq.Message) error {
 	defer cancel()
 
 	go func() {
-		ticker := time.NewTicker(5 * time.Second)
+		ticker := time.NewTicker(1 * time.Second)
 		defer ticker.Stop()
 
 		for {