Packages
exq
0.1.1
0.24.0
0.23.0
0.22.0
0.21.0
0.20.0
0.19.0
0.18.0
0.17.0
0.16.2
0.16.1
0.16.0
0.15.0
0.14.0
0.13.5
0.13.4
0.13.3
0.13.2
0.13.1
0.13.0
0.12.2
0.12.1
0.12.0
0.11.0
0.10.1
0.10.0
0.9.1
0.9.0
0.8.7
0.8.6
0.8.5
0.8.4
0.8.3
0.8.2
0.8.1
0.8.0
0.7.3
0.7.2
0.7.1
0.7.0
0.6.5
0.6.4
0.6.3
0.6.2
0.6.1
0.6.0
0.5.0
0.4.4
0.4.3
0.4.2
0.4.1
0.4.0
0.3.0
0.2.3
0.2.2
0.2.1
0.2.0
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
0.0.2
Exq is a job processing library compatible with Resque / Sidekiq for the Elixir language.
Current section
Files
Jump to
Current section
Files
lib/mix/tasks/exq.run.ex
defmodule Mix.Tasks.Exq.Run do
use Mix.Task
@shortdoc "Starts the Exq worker"
def run(args) do
{opts, args, _} = OptionParser.parse args,
switches: [host: :string, port: :integer, namespace: :string, queues: :string, webport: :integer]
app = parse_app(args)
if app do
app.start(nil)
end
opts = Keyword.put(opts, :host, to_char_list(Keyword.get(opts, :host, "127.0.0.1")))
{:ok, pid} = Exq.start(opts)
IO.puts "Started Exq with redis options: Host: #{opts[:host]}, Port: #{opts[:port]}, Namespace: #{opts[:namespace]}"
:timer.sleep(:infinity)
end
def parse_app([h|t]) when is_binary(h) and h != "" do
{Module.concat([h]), t}
end
def parse_app([h|t]) when is_atom(h) and h != :"" do
{h, t}
end
def parse_app(_) do
nil
#raise Mix.Error, message: "invalid arguments, expected an applicaiton as first argument"
end
end