@@ -22,19 +22,38 @@ defmodule Flume.API do
2222 end
2323
2424 def enqueue ( queue , worker , function_name , args , opts ) do
25- apply ( Flume.Config . queue_api_module ( ) , :enqueue , [ queue , worker , function_name , args , opts ] )
25+ apply ( Flume.Config . queue_api_module ( ) , :enqueue , [
26+ queue ,
27+ worker ,
28+ function_name ,
29+ args ,
30+ opts
31+ ] )
2632 end
2733
2834 def enqueue_in ( queue , time_in_seconds , worker , args ) do
2935 apply ( Flume.Config . queue_api_module ( ) , :enqueue_in , [ queue , time_in_seconds , worker , args ] )
3036 end
3137
3238 def enqueue_in ( queue , time_in_seconds , worker , function_name , args ) do
33- apply ( Flume.Config . queue_api_module ( ) , :enqueue_in , [ queue , time_in_seconds , worker , function_name , args ] )
39+ apply ( Flume.Config . queue_api_module ( ) , :enqueue_in , [
40+ queue ,
41+ time_in_seconds ,
42+ worker ,
43+ function_name ,
44+ args
45+ ] )
3446 end
3547
3648 def enqueue_in ( queue , time_in_seconds , worker , function_name , args , opts ) do
37- apply ( Flume.Config . queue_api_module ( ) , :enqueue_in , [ queue , time_in_seconds , worker , function_name , args , opts ] )
49+ apply ( Flume.Config . queue_api_module ( ) , :enqueue_in , [
50+ queue ,
51+ time_in_seconds ,
52+ worker ,
53+ function_name ,
54+ args ,
55+ opts
56+ ] )
3857 end
3958
4059 def pause_all ( temporary \\ true ) do
0 commit comments