From 28c8274eab7e9c8db41a6d1f3e5876b608060506 Mon Sep 17 00:00:00 2001 From: Silvan Date: Thu, 24 Dec 2020 13:01:23 +0100 Subject: [PATCH] fix(auth): spooler locks correct database (#1134) --- internal/admin/repository/eventsourcing/handler/handler.go | 6 ------ internal/auth/repository/eventsourcing/spooler/lock.go | 5 +++-- 2 files changed, 3 insertions(+), 8 deletions(-) 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 {