From 482914aef4a7d637a8c468d46904fde9f478b5d1 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 13 Sep 2022 15:25:02 +0100
Subject: [PATCH] Use `AckNone` on the ephemeral room input consumer

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

diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
index a8a3e0248..1cb980dc3 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -172,11 +172,10 @@ func (r *Inputer) Start() error {
 		func(m *nats.Msg) {
 			roomID := m.Header.Get(jetstream.RoomID)
 			r.startWorkerForRoom(roomID)
-			_ = m.Ack()
 		},
 		nats.HeadersOnly(),
 		nats.DeliverAll(),
-		nats.AckAll(),
+		nats.AckNone(),
 		nats.BindStream(r.InputRoomEventTopic),
 	)
 	return err