diff --git a/changelog/unreleased/publish-events-synchronously.md b/changelog/unreleased/publish-events-synchronously.md new file mode 100644 index 0000000000..f08f8ec75b --- /dev/null +++ b/changelog/unreleased/publish-events-synchronously.md @@ -0,0 +1,5 @@ +Bugfix: Publish events synchrously + +Async publishing can lead to loss of events under some circumstances + +https://github.com/cs3org/reva/pull/4047 diff --git a/go.mod b/go.mod index b3be6d8aeb..bf1391fc66 100644 --- a/go.mod +++ b/go.mod @@ -26,7 +26,7 @@ require ( github.com/gdexlab/go-render v1.0.1 github.com/go-chi/chi/v5 v5.0.8 github.com/go-ldap/ldap/v3 v3.4.5 - github.com/go-micro/plugins/v4/events/natsjs v1.2.0 + github.com/go-micro/plugins/v4/events/natsjs v1.2.1 github.com/go-micro/plugins/v4/server/http v1.2.1 github.com/go-micro/plugins/v4/store/nats-js v1.1.0 github.com/go-micro/plugins/v4/store/redis v1.2.1-0.20230510195111-07cd57e1bc9d diff --git a/go.sum b/go.sum index 0556e6e770..b194413050 100644 --- a/go.sum +++ b/go.sum @@ -605,8 +605,8 @@ github.com/go-logr/logr v1.2.4 h1:g01GSCwiDw2xSZfjJ2/T9M+S6pFdcNtFYsp+Y43HYDQ= github.com/go-logr/logr v1.2.4/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A= github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag= github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE= -github.com/go-micro/plugins/v4/events/natsjs v1.2.0 h1:c+iG3FholfRJI27QkIVPWOERazwDZro4GLl6Odx2g1c= -github.com/go-micro/plugins/v4/events/natsjs v1.2.0/go.mod h1:lYuiEYKQTpbE2LA8HEcC8D6kQ29M7ILfEak3dzeucEg= +github.com/go-micro/plugins/v4/events/natsjs v1.2.1 h1:wCq5pyUkHSJ31QAtTLiIRowNMe2OFQysg7fjw3SPJZ4= +github.com/go-micro/plugins/v4/events/natsjs v1.2.1/go.mod h1:lYuiEYKQTpbE2LA8HEcC8D6kQ29M7ILfEak3dzeucEg= github.com/go-micro/plugins/v4/registry/consul v1.2.0 h1:nqrTzfWUTWKAy+M+i2FazbHnQn4m77EOtoch57kbCH4= github.com/go-micro/plugins/v4/registry/consul v1.2.0/go.mod h1:wTat7/K9XQ+i64VbbcMYFcEwipYfSgJM51HcA/sgsM4= github.com/go-micro/plugins/v4/registry/etcd v1.2.0 h1:tcHlU1GzvX3oZa8WQH8ylMCGie5qD5g98YWTESJjeqQ= diff --git a/pkg/events/stream/nats.go b/pkg/events/stream/nats.go index 7eb940867a..642dcc32d0 100644 --- a/pkg/events/stream/nats.go +++ b/pkg/events/stream/nats.go @@ -52,6 +52,7 @@ func NatsFromConfig(cfg NatsConfig) (events.Stream, error) { natsjs.TLSConfig(tlsConf), natsjs.Address(cfg.Endpoint), natsjs.ClusterID(cfg.Cluster), + natsjs.SynchronousPublish(true), ) }