diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-09-13 15:25:02 +0100 |
|---|---|---|
| committer | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-09-13 15:25:02 +0100 |
| commit | 482914aef4a7d637a8c468d46904fde9f478b5d1 (patch) | |
| tree | 1c53e1fde495287303e282beab7f3e229db9ebbc /roomserver | |
| parent | b05e028f7d8befc045dcb62e87d09ad462bb277c (diff) | |
Use `AckNone` on the ephemeral room input consumer
Diffstat (limited to 'roomserver')
| -rw-r--r-- | roomserver/internal/input/input.go | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go index a8a3e024..1cb980dc 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 |