diff --git a/maintnotifications/pool_hook.go b/maintnotifications/pool_hook.go index 695c3a64..f8093524 100644 --- a/maintnotifications/pool_hook.go +++ b/maintnotifications/pool_hook.go @@ -174,6 +174,10 @@ func (ph *PoolHook) OnPut(ctx context.Context, conn *pool.Conn) (shouldPool bool return true, false, nil } +func (ph *PoolHook) OnRemove(_ context.Context, _ *pool.Conn, _ error) { + // Not used +} + // Shutdown gracefully shuts down the processor, waiting for workers to complete func (ph *PoolHook) Shutdown(ctx context.Context) error { return ph.workerManager.shutdownWorkers(ctx) diff --git a/redis.go b/redis.go index d0f37c6b..d0667b50 100644 --- a/redis.go +++ b/redis.go @@ -217,9 +217,7 @@ type baseClient struct { pubSubPool *pool.PubSubPool hooksMixin - onClose func() error // hook called when client is closed - onCloseSlice []func() error - onCloseMu sync.Mutex + onClose func() error // hook called when client is closed // Push notification processing pushProcessor push.NotificationProcessor