From 1f10bce9990d71ba30e1aaf2df8111dbbce10669 Mon Sep 17 00:00:00 2001
From: Neil Alexander <neilalexander@users.noreply.github.com>
Date: Tue, 22 Mar 2022 16:52:50 +0000
Subject: [PATCH] Don't drop events

---
 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 0187dd522..988e26614 100644
--- a/roomserver/internal/input/input.go
+++ b/roomserver/internal/input/input.go
@@ -144,10 +144,11 @@ 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.AckNone(),
+		nats.AckAll(),
 		nats.BindStream(r.InputRoomEventTopic),
 	)
 	return err