Ensure delegate registers handlers (#41)

tidepool-org · Apr 12, 2021 · 77cdb96 · 77cdb96
1 parent 06b8f0b
commit 77cdb96
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/events/fault_tolerant_consumer.go b/events/fault_tolerant_consumer.go
@@ -81,7 +81,7 @@ func (f *FaultTolerantConsumer) recreateConsumer() error {
 
 	f.delegate = delegate
 	for _, h := range f.handlers {
-		f.RegisterHandler(h)
+		f.delegate.RegisterHandler(h)
 	}
 	return nil
 }