diff --git a/producer/processor.go b/producer/processor.go
index 32b6cb4..a44c0f4 100644
--- a/producer/processor.go
+++ b/producer/processor.go
@@ -123,6 +123,7 @@ func (p *processor) StartMonitoring() {
 		if err := recover(); err != nil {
 			p.handler.NotifyError(err.(error))
 		}
+		p.handler.DecreaseWait()
 	}()
 
 	tempeturePathGlob := path.Join(p.tempeturePath, "temp?_input")