Use explicit ack on supervisor consumer, now durable

neilalexander · Dec 11, 2024 · fa5128a · fa5128a
1 parent 71e722a
commit fa5128a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go
@@ -232,10 +232,12 @@ func (r *Inputer) Start() error {
 		func(m *nats.Msg) {
 			roomID := m.Header.Get(jetstream.RoomID)
 			r.startWorkerForRoom(roomID)
+			_ = m.AckSync()
 		},
 		nats.HeadersOnly(),
 		nats.BindStream(r.InputRoomEventTopic),
-		nats.OrderedConsumer(),
+		nats.Durable("supervisor"),
+		nats.ManualAck(),
 	)
 
 	// Make sure that the room consumers have the right config.