Use AckNone on the ephemeral room input consumer

2022-09-13 15:25:02 +01:00 · 2022-09-13 15:25:02 +01:00 · 482914aef4
parent b05e028f7d
commit 482914aef4
1 changed files with 1 additions and 2 deletions
--- 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