diff options
Diffstat (limited to 'federationsender/consumers/eduserver.go')
| -rw-r--r-- | federationsender/consumers/eduserver.go | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/federationsender/consumers/eduserver.go b/federationsender/consumers/eduserver.go index e1a42f07..d9ac41b3 100644 --- a/federationsender/consumers/eduserver.go +++ b/federationsender/consumers/eduserver.go @@ -50,11 +50,13 @@ func NewOutputEDUConsumer( ) *OutputEDUConsumer { c := &OutputEDUConsumer{ typingConsumer: &internal.ContinualConsumer{ + ComponentName: "eduserver/typing", Topic: string(cfg.Matrix.Kafka.TopicFor(config.TopicOutputTypingEvent)), Consumer: kafkaConsumer, PartitionStore: store, }, sendToDeviceConsumer: &internal.ContinualConsumer{ + ComponentName: "eduserver/sendtodevice", Topic: string(cfg.Matrix.Kafka.TopicFor(config.TopicOutputSendToDeviceEvent)), Consumer: kafkaConsumer, PartitionStore: store, |