From 3e113fd14f3030bacf71bd41d9fd804c141ac92f Mon Sep 17 00:00:00 2001 From: Till Faelligen <2353100+S7evinK@users.noreply.github.com> Date: Fri, 1 Dec 2023 08:31:51 +0100 Subject: [PATCH] Fix thinko, actually produce to the correct stream/topic --- syncapi/producers/appservices.go | 1 + 1 file changed, 1 insertion(+) diff --git a/syncapi/producers/appservices.go b/syncapi/producers/appservices.go index b34fdc43e..f6f150281 100644 --- 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