Call the throttler.Teardown

2018-01-11 08:03:09 +02:00 · 2018-01-11 08:03:09 +02:00 · 02579075d0
commit 02579075d0
parent 9226769a22
1 changed files with 5 additions and 0 deletions
--- a/go/logic/migrator.go
+++ b/go/logic/migrator.go
@ -1262,4 +1262,9 @@ func (this *Migrator) teardown() {
 		log.Infof("Tearing down streamer")
 		this.eventsStreamer.Teardown()
 	}
+
+	if this.throttler != nil {
+		log.Infof("Tearing down throttler")
+		this.throttler.Teardown()
+	}
 }