- Swithc from value to pointer to the pool configuration. Interface

  value changed.

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

1 files changed, 10 insertions, 0 deletions

diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go
index 072f872a..e7466efb 100644
--- a/plugins/jobs/plugin.go
+++ b/plugins/jobs/plugin.go
@@ -45,6 +45,11 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Se
 		return errors.E(op, err)
 	}
 
+	err = p.cfg.InitDefaults()
+	if err != nil {
+		return errors.E(op, err)
+	}
+
 	p.workersPool, err = server.NewWorkerPool(context.Background(), p.cfg.poolCfg, map[string]string{RrJobs: "true"}, testListener)
 	if err != nil {
 		return errors.E(op, err)
@@ -60,6 +65,11 @@ func (p *Plugin) Init(cfg config.Configurer, log logger.Logger, server server.Se
 func (p *Plugin) Serve() chan error {
 	errCh := make(chan error, 1)
 
+	// initialize sub-plugins
+	// provide a queue to them
+	// start consume loop
+	// start resp loop
+
 	return errCh
 }