Change retry

This commit is contained in:
kolaente 2021-01-31 15:48:02 +01:00
parent 124cc5e54f
commit 7fd3322533
Signed by: konrad
GPG Key ID: F40E70337AB24C9B
2 changed files with 4 additions and 2 deletions

View File

@ -48,9 +48,10 @@ func InitEvents() (err error) {
router.AddMiddleware( router.AddMiddleware(
middleware.Retry{ middleware.Retry{
MaxRetries: 3, MaxRetries: 5,
InitialInterval: time.Millisecond * 100, InitialInterval: time.Millisecond * 100,
Logger: logger, Logger: logger,
Multiplier: 2,
}.Middleware, }.Middleware,
middleware.Recoverer, middleware.Recoverer,
) )

View File

@ -17,9 +17,10 @@
package models package models
import ( import (
"encoding/json"
"code.vikunja.io/api/pkg/events" "code.vikunja.io/api/pkg/events"
"code.vikunja.io/api/pkg/log" "code.vikunja.io/api/pkg/log"
"encoding/json"
"github.com/ThreeDotsLabs/watermill/message" "github.com/ThreeDotsLabs/watermill/message"
) )