From 14bf1f8a0922d761f6e52840d3f8fe50107f100d Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Thu, 4 Nov 2021 12:40:15 +0000 Subject: [PATCH] Tweak delivery options on RS input --- 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 05803a40..e31efd15 100644 --- a/roomserver/internal/input/input.go +++ b/roomserver/internal/input/input.go @@ -65,9 +65,9 @@ func (r *Inputer) Start() error { } inbox, _ := r.workers.LoadOrStore(roomID, &phony.Inbox{}) inbox.(*phony.Inbox).Act(nil, func() { + _ = msg.InProgress() if _, err := r.processRoomEvent(context.TODO(), &inputRoomEvent); err != nil { sentry.CaptureException(err) - } else { hooks.Run(hooks.KindNewEventPersisted, inputRoomEvent.Event) } @@ -75,6 +75,7 @@ func (r *Inputer) Start() error { }) }, nats.ManualAck(), + nats.MaxDeliver(0), ) return err }