From fd4c6a4fe5507834f4519223f4170d08c2e28f1a Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Wed, 3 Nov 2021 14:36:27 +0000
Subject: [PATCH] Roomserver output topic

---
 roomserver/internal/input/input.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index 42d38082..b5a45470 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)