diff options
| author | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-01-31 10:42:41 +0000 |
|---|---|---|
| committer | Neil Alexander <neilalexander@users.noreply.github.com> | 2022-01-31 10:42:41 +0000 |
| commit | eb8e770e9973fb22371a0a474fee7d10a981d800 (patch) | |
| tree | ae6ac46fe3bcdabc8ee417951d906fd2e80aca55 /roomserver | |
| parent | a271fde8f581389fd793e5064f88f70e90d50f66 (diff) | |
Revert consumer change
Diffstat (limited to 'roomserver')
| -rw-r--r-- | roomserver/internal/input/input.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/roomserver/internal/input/input.go b/roomserver/internal/input/input.go index 7933f975..938d5ac1 100644 --- a/roomserver/internal/input/input.go +++ b/roomserver/internal/input/input.go @@ -120,7 +120,7 @@ func (r *Inputer) Start() error { nats.DeliverAll(), // Ensure that NATS doesn't try to resend us something that wasn't done // within the period of time that we might still be processing it. - nats.AckWait((MaximumMissingProcessingTime*2)+(time.Second*10)), + nats.AckWait(MaximumMissingProcessingTime+(time.Second*10)), ) return err } |