Fix thinko, actually produce to the correct stream/topic

matrix-org · Dec 1, 2023 · 3e113fd · 3e113fd
1 parent 2188f4f
commit 3e113fd
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/syncapi/producers/appservices.go b/syncapi/producers/appservices.go
@@ -28,6 +28,7 @@ type AppserviceEventProducer struct {
 func (a *AppserviceEventProducer) ProduceRoomEvents(
 	msg *nats.Msg,
 ) error {
+	msg.Subject = a.Topic
 	if _, err := a.JetStream.PublishMsg(msg); err != nil {
 		logrus.WithError(err).Errorf("Failed to produce to topic '%s': %s", a.Topic, err)
 		return err