[Redis Broker] Wait for currently processing tasks to finish before c…

…losing the redis pool (#552)
RichardKnop · May 19, 2020 · c9512ae · c9512ae
1 parent 0bdd8fa
commit c9512ae
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/v1/brokers/redis/redis.go b/v1/brokers/redis/redis.go
@@ -161,6 +161,8 @@ func (b *Broker) StopConsuming() {
 	b.delayedWG.Wait()
 	// Waiting for consumption to finish
 	b.consumingWG.Wait()
+	// Wait for currently processing tasks to finish as well.
+	b.processingWG.Wait()
 
 	if b.pool != nil {
 		b.pool.Close()