diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-09-14 09:55:50 +0100 |
|---|---|---|
| committer | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-09-14 09:55:50 +0100 |
| commit | 7f89fed1e45cc6ea65c420e32a017df634f4164f (patch) | |
| tree | b80371fff77ceb61621ba9cb3de94ccb998a0604 /roomserver | |
| parent | 482914aef4a7d637a8c468d46904fde9f478b5d1 (diff) | |
Revert 482914aef4a7d637a8c468d46904fde9f478b5d1
Diffstat (limited to 'roomserver')
| -rw-r--r-- | roomserver/internal/input/input.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go index 1cb980dc..c47793f0 100644 --- a/roomserver/internal/input/input.go +++ b/roomserver/internal/input/input.go @@ -172,10 +172,12 @@ 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.AckExplicit(), + nats.ReplayInstant(), nats.BindStream(r.InputRoomEventTopic), ) return err |