From 4def2f695d9e353de77750c3958be5aa894495ec Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Fri, 14 Oct 2022 12:11:08 +0100
Subject: [PATCH] Update `PullSubscribe`

---
 roomserver/internal/input/input.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index bf0e3532a..2b63a0f22 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -152,6 +152,7 @@ func (r *Inputer) startWorkerForRoom(roomID string) {
 			nats.DeliverAll(),
 			nats.AckWait(MaximumMissingProcessingTime+(time.Second*10)),
 			nats.Bind(r.InputRoomEventTopic, consumer),
+			nats.InactiveThreshold(time.Hour),
 		)
 		if err != nil {
 			logrus.WithError(err).Errorf("Failed to subscribe to stream for room %q", w.roomID)