1 files changed, 28 insertions, 0 deletions
diff --git a/lib/presque/Role/RequireQueue.pm b/lib/presque/Role/RequireQueue.pm
new file mode 100644
index 0000000..f9e6ec7
--- /dev/null
+++ b/lib/presque/Role/RequireQueue.pm
@@ -0,0 +1,28 @@
+package presque::Role::RequireQueue;
+
+use MooseX::Role::Parameterized;
+
+parameter methods => (
+    isa      => 'ArrayRef',
+    required => 1,
+);
+
+role {
+    my $p = shift;
+
+    my $methods = $p->methods;
+
+    foreach my $m (@$methods) {
+        around $m => sub {
+            my $orig       = shift;
+            my $self       = shift;
+            my $queue_name = shift;
+
+            return $self->http_error_queue if !$queue_name;
+
+            $self->$orig($queue_name, @_);
+        };
+    }
+};
+
+1;