make sse service scalable

Signed-off-by: jkoberg <jkoberg@owncloud.com>
2023-09-28 14:08:03 +02:00
parent 836106d802
commit 9a981ffe24
3 changed files with 10 additions and 1 deletions
@@ -8,6 +8,7 @@ import (
 	"github.com/cs3org/reva/v2/pkg/events"
 	"github.com/go-chi/chi/v5"
 	chimiddleware "github.com/go-chi/chi/v5/middleware"
+	"github.com/google/uuid"
 	"github.com/owncloud/ocis/v2/ocis-pkg/account"
 	"github.com/owncloud/ocis/v2/ocis-pkg/cors"
 	"github.com/owncloud/ocis/v2/ocis-pkg/middleware"
@@ -78,7 +79,7 @@ func Server(opts ...Option) (http.Service, error) {
 		),
 	)

-	ch, err := events.Consume(options.Consumer, "sse", options.RegisteredEvents...)
+	ch, err := events.Consume(options.Consumer, "sse-"+uuid.New().String(), options.RegisteredEvents...)
 	if err != nil {
 		return http.Service{}, err
 	}