diff --git a/internal/admin/repository/eventsourcing/handler/handler.go b/internal/admin/repository/eventsourcing/handler/handler.go index e6fdc3e531..ed0e60f6ed 100644 --- a/internal/admin/repository/eventsourcing/handler/handler.go +++ b/internal/admin/repository/eventsourcing/handler/handler.go @@ -77,12 +77,6 @@ func Register(configs Configs, bulkLimit, errorCount uint64, view *view.View, es } } -func subscribe(es eventstore.Eventstore, handlers []query.Handler) { - for _, handler := range handlers { - es.Subscribe(handler.AggregateTypes()...) - } -} - func (configs Configs) cycleDuration(viewModel string) time.Duration { c, ok := configs[viewModel] if !ok { diff --git a/internal/auth/repository/eventsourcing/spooler/lock.go b/internal/auth/repository/eventsourcing/spooler/lock.go index f24f98f6cc..5b69f3ae0c 100644 --- a/internal/auth/repository/eventsourcing/spooler/lock.go +++ b/internal/auth/repository/eventsourcing/spooler/lock.go @@ -2,12 +2,13 @@ package spooler import ( "database/sql" - es_locker "github.com/caos/zitadel/internal/eventstore/locker" "time" + + es_locker "github.com/caos/zitadel/internal/eventstore/locker" ) const ( - lockTable = "management.locks" + lockTable = "auth.locks" ) type locker struct {