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

allow to issue commands with message id ( and message structs )

Browse Source
This commit is contained in:
Bruno Tavares
2014-09-03 11:02:54 +01:00
parent 7edb6bbfa0
commit ee0b61582a
1 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -167,7 +167,9 @@ sub mark_as_done_msg {
my ($self, $msg) = @_;
return unless my $hdl = $self->{handle};
$hdl->push_write("FIN $msg->{message_id}\012");
my $id = ref($msg) ? $msg->{message_id} : $msg;
$hdl->push_write("FIN $id\012");
return;
}
@@ -176,10 +178,13 @@ sub requeue_msg {
my ($self, $msg, $delay) = @_;
return unless my $hdl = $self->{handle};
$delay = 0 unless defined $delay;
$delay = $msg->{attempts} * $self->{requeue_delay} if $delay < 0;
my $id = ref($msg) ? $msg->{message_id} : $msg;
my $attempts = ref($msg) ? $msg->{attempts} : 1;
$hdl->push_write("REQ $msg->{message_id} $delay\012");
$delay = 0 unless defined $delay;
$delay = $attempts * $self->{requeue_delay} if $delay < 0;
$hdl->push_write("REQ $id $delay\012");
return;
}
@@ -188,7 +193,8 @@ sub touch_msg {
my ($self, $msg) = @_;
return unless my $hdl = $self->{handle};
$hdl->push_write("TOUCH $msg->{message_id}\012");
my $id = ref($msg) ? $msg->{message_id} : $msg;
$hdl->push_write("TOUCH $id\012");
return;
}