A simple job queue using OTP.
def deps do
[{:bolt, "~> 0.1.2"}]
end
#config.ex
config :bolt,
queues: [{:main, SomeApp.SomeWorker}, {:main, SomeApp.SomeWorker}],
redis_url: "redis://localhost:6379",
port: 3000
defmodule SomeApp.SomeWorker do
@behaviour Bolt.Worker
def work(params) do
#Do some work!
end
end
Bolt.Queue.enqueue(:bg, %{a: 1, b: 2})
GET localhost:3000/
change the port by setting in config or set to nil to disable endpoint.
[
{
"workers": [],
"worker_max": 1,
"status": "running",
"queue_name": "main",
"jobs_remaining": 0
},
{
"workers": [
{
"status": "finished",
"started_at": "2017-07-08T00:04:49.773760Z",
"job_id": "bg:jobs:id69050946-636e-11e7-bd14-784f437e1c56"
}
],
"worker_max": 1,
"status": "running",
"queue_name": "bg",
"jobs_remaining": 167804
}
]