Try switching back to original WorkerPool.

mailgun · Oct 10, 2023 · a963c28 · a963c28
1 parent 5aaf36e
commit a963c28
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/gubernator.go b/gubernator.go
@@ -49,7 +49,7 @@ type V1Instance struct {
 	log                  FieldLogger
 	conf                 Config
 	isClosed             bool
-	workerPool           *WorkerPool2
+	workerPool           *WorkerPool
 }
 
 var metricGetRateLimitCounter = prometheus.NewCounterVec(prometheus.CounterOpts{
@@ -125,7 +125,7 @@ func NewV1Instance(conf Config) (s *V1Instance, err error) {
 		conf: conf,
 	}
 
-	s.workerPool = NewWorkerPool2(&conf)
+	s.workerPool = NewWorkerPool(&conf)
 	s.global = newGlobalManager(conf.Behaviors, s)
 
 	// Register our instance with all GRPC servers