diff options
Diffstat (limited to 'plugins')
| -rw-r--r-- | plugins/jobs/plugin.go | 13 |
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 } |