From 8fe77e0d001c6d0889c82a3a1c5c81de963256f3 Mon Sep 17 00:00:00 2001
From: Till Faelligen <2353100+S7evinK@users.noreply.github.com>
Date: Sat, 16 Dec 2023 20:18:34 +0100
Subject: [PATCH] Fix thinko

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

diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index 5f67e0d251..fbcc18adf5 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -142,7 +142,7 @@ func (r *Inputer) startWorkerForRoom(roomID string) {
 		// will linger around forever.
 
 		info, err := w.r.JetStream.ConsumerInfo(streamName, consumer)
-		if err != nil {
+		if err != nil && !errors.Is(err, nats.ErrConsumerNotFound) {
 			// log and return, we will retry anyway
 			logger.WithError(err).Errorf("failed to get consumer info")
 			return