diff options
Diffstat (limited to 'lib/presque')
-rw-r--r-- | lib/presque/ControlHandler.pm | 13 | ||||
-rw-r--r-- | lib/presque/StatusHandler.pm | 7 | ||||
-rw-r--r-- | lib/presque/StreamHandler.pm | 14 | ||||
-rw-r--r-- | lib/presque/WorkerHandler.pm | 6 |
4 files changed, 28 insertions, 12 deletions
diff --git a/lib/presque/ControlHandler.pm b/lib/presque/ControlHandler.pm index ccfc663..7feadc8 100644 --- a/lib/presque/ControlHandler.pm +++ b/lib/presque/ControlHandler.pm @@ -4,12 +4,11 @@ use JSON; use Moose; extends 'Tatsumaki::Handler'; -with ( - 'presque::Role::QueueName', +with + 'presque::Role::Queue::Names', 'presque::Role::Error', 'presque::Role::Response', - 'presque::Role::RequireQueue' => {methods => [qw/get post/]}, -); + 'presque::Role::Queue::WithQueueName' => {methods => [qw/get post/]},; __PACKAGE__->asynchronous(1); @@ -81,7 +80,7 @@ presque::ControlHandler =head1 DESCRIPTION -By default, when a queue is created, the status is set to 'open'. When a queue is set to 'stop', no job will be fetched from the queue. +By default, when a queue is created, the status is set to 'open'. When a queue is set to 'stop', no job will be fetched from the queue, but it's still possible to add new jobs. =head1 METHODS @@ -91,7 +90,7 @@ By default, when a queue is created, the status is set to 'open'. When a queue i =item path -/control/queuename +/control/:queuename =item request @@ -111,7 +110,7 @@ content : {"status":"0","queue":"foo"} =item path -/control/queuename +/control/:queuename =item request diff --git a/lib/presque/StatusHandler.pm b/lib/presque/StatusHandler.pm index ee0abce..778aeb4 100644 --- a/lib/presque/StatusHandler.pm +++ b/lib/presque/StatusHandler.pm @@ -1,14 +1,15 @@ package presque::StatusHandler; +use JSON; use Moose; extends 'Tatsumaki::Handler'; with - qw/presque::Role::QueueName presque::Role::Error presque::Role::Response/; + 'presque::Role::Queue::Names', + 'presque::Role::Error', + 'presque::Role::Response'; __PACKAGE__->asynchronous(1); -use JSON; - sub get { my ($self, $queue_name) = @_; diff --git a/lib/presque/StreamHandler.pm b/lib/presque/StreamHandler.pm new file mode 100644 index 0000000..fe88b76 --- /dev/null +++ b/lib/presque/StreamHandler.pm @@ -0,0 +1,14 @@ +package presque::StreamHandler; + +use JSON; +use Moose; +extends 'Tatsumaki::Handler'; +with qw/presque::Role::QueueName presque::Role::Response/; + +__PACKAGE__->asynchronous(1); + +sub get { + my ($self, $queue_name) = @_; +} + +1; diff --git a/lib/presque/WorkerHandler.pm b/lib/presque/WorkerHandler.pm index 0421729..4399ddf 100644 --- a/lib/presque/WorkerHandler.pm +++ b/lib/presque/WorkerHandler.pm @@ -3,8 +3,10 @@ package presque::WorkerHandler; use JSON; use Moose; extends 'Tatsumaki::Handler'; -with('presque::Role::Error', 'presque::Role::Response', - 'presque::Role::RequireQueue' => {methods => [qw/delete post/]}); +with + 'presque::Role::Error', + 'presque::Role::Response', + 'presque::Role::Queue::WithQueueName' => {methods => [qw/delete post/]}; __PACKAGE__->asynchronous(1); |