From dd7f69ffc384c887679385a9c4132497a38d2cf7 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Wed, 3 Nov 2021 14:31:24 +0000 Subject: [PATCH] Add missing topic --- syncapi/consumers/eduserver_typing.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/syncapi/consumers/eduserver_typing.go b/syncapi/consumers/eduserver_typing.go index 03166a96e..f6f63050b 100644 --- a/syncapi/consumers/eduserver_typing.go +++ b/syncapi/consumers/eduserver_typing.go @@ -21,6 +21,7 @@ import ( "github.com/matrix-org/dendrite/eduserver/api" "github.com/matrix-org/dendrite/eduserver/cache" "github.com/matrix-org/dendrite/setup/config" + "github.com/matrix-org/dendrite/setup/jetstream" "github.com/matrix-org/dendrite/setup/process" "github.com/matrix-org/dendrite/syncapi/notifier" "github.com/matrix-org/dendrite/syncapi/storage" @@ -51,6 +52,7 @@ func NewOutputTypingEventConsumer( ) *OutputTypingEventConsumer { return &OutputTypingEventConsumer{ jetstream: js, + topic: cfg.Matrix.JetStream.TopicFor(jetstream.OutputTypingEvent), eduCache: eduCache, notifier: notifier, stream: stream,