Current section
8 Versions
Jump to
Current section
8 Versions
Compare versions
5
files changed
+15
additions
-15
deletions
| @@ -5,7 +5,7 @@ Conqueuer (pronounced like conquer) is a non-persistent Elixir work queue. | |
| 5 5 | |
| 6 6 | ### Documentation and Information |
| 7 7 | |
| 8 | - The [docs](http://hexdocs.pm/conqueuer/0.4.0/Conqueuer.html) can be found on the |
| 8 | + The [docs](http://hexdocs.pm/conqueuer/0.5.0/Conqueuer.html) can be found on the |
| 9 9 | hexdocs website and [further information](https://hex.pm/packages/conqueuer) on the |
| 10 10 | hex website. |
| 11 11 | |
| @@ -17,7 +17,7 @@ Conqueuer can be installed like: | |
| 17 17 | 1. Add test to your list of dependencies in `mix.exs`: |
| 18 18 | |
| 19 19 | def deps do |
| 20 | - [{:conqueuer, "~> 0.4.0"}] |
| 20 | + [{:conqueuer, "~> 0.5.0"}] |
| 21 21 | end |
| 22 22 | |
| 23 23 | 2. Ensure test is started before your application: |
| @@ -20,4 +20,4 @@ | |
| 20 20 | [{<<"app">>,<<"poolboy">>}, |
| 21 21 | {<<"optional">>,false}, |
| 22 22 | {<<"requirement">>,<<"~> 1.5">>}]}]}. |
| 23 | - {<<"version">>,<<"0.4.0">>}. |
| 23 | + {<<"version">>,<<"0.5.0">>}. |
| @@ -60,7 +60,7 @@ defmodule Conqueuer do | |
| 60 60 | defmodule MyApp.ResolverWorker do |
| 61 61 | use Conqueuer.Worker |
| 62 62 | |
| 63 | - def perform({arg1, arg2}) do |
| 63 | + def perform({arg1, arg2}, state) do |
| 64 64 | # do some work |
| 65 65 | end |
| 66 66 | end |
| @@ -6,7 +6,7 @@ defmodule Conqueuer.Worker do | |
| 6 6 | defmodule MyApp.ResolverWorker do |
| 7 7 | use Conqueuer.Worker |
| 8 8 | |
| 9 | - def perform do |
| 9 | + def perform(state) do |
| 10 10 | end |
| 11 11 | end |
| 12 12 | |
| @@ -15,7 +15,7 @@ defmodule Conqueuer.Worker do | |
| 15 15 | defmodule MyApp.ResolverWorker do |
| 16 16 | use Conqueuer.Worker |
| 17 17 | |
| 18 | - def perform(param) do |
| 18 | + def perform(param, state) do |
| 19 19 | end |
| 20 20 | end |
| 21 21 | |
| @@ -24,7 +24,7 @@ defmodule Conqueuer.Worker do | |
| 24 24 | defmodule MyApp.ResolverWorker do |
| 25 25 | use Conqueuer.Worker |
| 26 26 | |
| 27 | - def perform({param1, param2}) do |
| 27 | + def perform({param1, param2}, state) do |
| 28 28 | end |
| 29 29 | end |
| 30 30 | """ |
| @@ -43,9 +43,9 @@ defmodule Conqueuer.Worker do | |
| 43 43 | |
| 44 44 | def handle_cast( {:work, foreman, args}, state ) do |
| 45 45 | if args == nil do |
| 46 | - perform |
| 46 | + perform state |
| 47 47 | else |
| 48 | - perform args |
| 48 | + perform args, state |
| 49 49 | end |
| 50 50 | |
| 51 51 | Conqueuer.Foreman.finished foreman, self |
| @@ -53,15 +53,15 @@ defmodule Conqueuer.Worker do | |
| 53 53 | {:noreply, state} |
| 54 54 | end |
| 55 55 | |
| 56 | - def perform do |
| 57 | - raise "You must define a perform/0 function in your worker" |
| 58 | - end |
| 59 | - |
| 60 56 | def perform(_) do |
| 61 57 | raise "You must define a perform/1 function in your worker" |
| 62 58 | end |
| 63 59 | |
| 64 | - defoverridable [ perform: 0, perform: 1 ] |
| 60 | + def perform(_,_) do |
| 61 | + raise "You must define a perform/1 function in your worker" |
| 62 | + end |
| 63 | + |
| 64 | + defoverridable [ perform: 1, perform: 2 ] |
| 65 65 | end |
| 66 66 | end |
| @@ -3,7 +3,7 @@ defmodule Conqueuer.Mixfile do | |
| 3 3 | |
| 4 4 | def project do |
| 5 5 | [app: :conqueuer, |
| 6 | - version: "0.4.0", |
| 6 | + version: "0.5.0", |
| 7 7 | elixir: "~> 1.1", |
| 8 8 | build_embedded: Mix.env == :prod, |
| 9 9 | preferred_cli_env: [espec: :test], |