diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index 42d38082f..b5a45470c 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -111,7 +111,8 @@ func (r *Inputer) WriteOutputEvents(roomID string, updates []api.OutputEvent) er
 	var err error
 	for _, update := range updates {
 		msg := &nats.Msg{
-			Header: nats.Header{},
+			Subject: r.OutputRoomEventTopic,
+			Header:  nats.Header{},
 		}
 		msg.Header.Set(jetstream.RoomID, roomID)
 		msg.Data, err = json.Marshal(update)