diff --git a/src/github.com/matrix-org/dendrite/federationsender/federationsender.go b/src/github.com/matrix-org/dendrite/federationsender/federationsender.go index ed3a1a1f8..9b732b386 100644 --- a/src/github.com/matrix-org/dendrite/federationsender/federationsender.go +++ b/src/github.com/matrix-org/dendrite/federationsender/federationsender.go @@ -46,7 +46,9 @@ func SetupFederationSenderComponent( logrus.WithError(err).Panic("failed to start room server consumer") } - tsConsumer := consumers.NewOutputTypingEventConsumer(cfg, kafkaConsumer, queues, store) + tsConsumer := consumers.NewOutputTypingEventConsumer( + base.Cfg, base.KafkaConsumer, queues, federationSenderDB, + ) if err := tsConsumer.Start(); err != nil { logrus.WithError(err).Panic("failed to start typing server consumer") }