- Update jobs interface

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

1 files changed, 13 insertions, 0 deletions

diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go
index 90932edd..8c5a665e 100644
--- a/plugins/jobs/plugin.go
+++ b/plugins/jobs/plugin.go
@@ -95,6 +95,19 @@ func (p *Plugin) Serve() chan error {
 	// start consume loop
 	// start resp loop
 
+	/*
+		go func() {
+			for {
+				// get data JOB from the queue
+				job := p.queue.Pop()
+
+				// request
+				_ = job
+				p.workersPool.Exec(nil)
+			}
+		}()
+
+	*/
 	return errCh
 }