summary refs log tree commit diff
path: root/lib/presque/worker/Middleware/ClientID.pm
diff options
context:
space:
mode:
Diffstat (limited to 'lib/presque/worker/Middleware/ClientID.pm')
-rw-r--r--lib/presque/worker/Middleware/ClientID.pm16
1 files changed, 16 insertions, 0 deletions
diff --git a/lib/presque/worker/Middleware/ClientID.pm b/lib/presque/worker/Middleware/ClientID.pm
new file mode 100644
index 0000000..c2a89a6
--- /dev/null
+++ b/lib/presque/worker/Middleware/ClientID.pm
@@ -0,0 +1,16 @@
+package presque::worker::Middleware::ClientID;
+
+use Moose;
+extend 'Net::HTTP::Spore::Middleware';
+
+has worker_id => ( is => 'rw', isa => 'Str', predicate => 'has_worker_id' );
+
+sub call {
+    my ( $self, $req ) = @_;
+
+    if ( $self->has_worker_id ) {
+        $req->header( 'X-presque-workerid' => $self->worker_id );
+    }
+}
+
+1;