From c7c6038397a236ac2f7df18d2f1463f97aa20fc4 Mon Sep 17 00:00:00 2001
From: Pedro Melo <melo@simplicidade.org>
Date: Sun, 20 Jul 2014 17:39:56 +0100
Subject: [PATCH] Fix: wrong requeue_msg() impl fixed, with support for
 requeue_delay

Signed-off-by: Pedro Melo <melo@simplicidade.org>
---
 lib/AnyEvent/NSQ/Connection.pm | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/lib/AnyEvent/NSQ/Connection.pm b/lib/AnyEvent/NSQ/Connection.pm
index 25cddd0..f11b4a6 100644
--- a/lib/AnyEvent/NSQ/Connection.pm
+++ b/lib/AnyEvent/NSQ/Connection.pm
@@ -136,7 +136,10 @@ sub requeue_msg {
   my ($self, $msg, $delay) = @_;
   return unless my $hdl = $self->{handle};
 
-  $hdl->push_write("FIN $msg->{message_id}\012");
+  $delay = 0 unless defined $delay;
+  $delay = $msg->{attempts} * $self->{requeue_delay} if $delay < 0;
+
+  $hdl->push_write("REQ $msg->{message_id} $delay\012");
 
   return;
 }