- Remove all old code, reformat, fix linters, return GA

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 12 insertions, 1 deletions

diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go
index 42203871..cda2a711 100644
--- a/plugins/jobs/plugin.go
+++ b/plugins/jobs/plugin.go
@@ -1,10 +1,14 @@
 package jobs
 
 import (
+	"context"
+
 	endure "github.com/spiral/endure/pkg/container"
 	"github.com/spiral/errors"
+	"github.com/spiral/roadrunner/v2/pkg/pool"
 	"github.com/spiral/roadrunner/v2/plugins/config"
 	"github.com/spiral/roadrunner/v2/plugins/logger"
+	"github.com/spiral/roadrunner/v2/plugins/server"
 )
 
 const (
@@ -15,10 +19,12 @@ type Plugin struct {
 	cfg *Config
 	log logger.Logger
 
+	workersPool pool.Pool
+
 	consumers map[string]Consumer
 }
 
-func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error {
+func (p *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Server) error {
 	const op = errors.Op("jobs_plugin_init")
 	if !cfg.Has(PluginName) {
 		return errors.E(op, errors.Disabled)
@@ -29,6 +35,11 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger) error {
 		return errors.E(op, err)
 	}
 
+	p.workersPool, err = server.NewWorkerPool(context.Background(), p.cfg.poolCfg, nil, nil)
+	if err != nil {
+		return errors.E(op, err)
+	}
+
 	p.consumers = make(map[string]Consumer)
 	p.log = log
 	return nil