dinislage/perl-anyevent-nsq
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix: wrong requeue_msg() impl fixed, with support for requeue_delay

Browse Source 
Signed-off-by: Pedro Melo <melo@simplicidade.org>
This commit is contained in:
Pedro Melo
2014-07-20 17:39:56 +01:00
parent 522f4e1670
commit c7c6038397
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lib/AnyEvent/NSQ/Connection.pm
View File

@@ -136,7 +136,10 @@ sub requeue_msg {
my ($self, $msg, $delay) = @_; my ($self, $msg, $delay) = @_;
return unless my $hdl = $self->{handle}; 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; return;
} }