From 36c67c9586d7bf4086d57763b3f1a410bcb1b9d2 Mon Sep 17 00:00:00 2001 From: Pedro Melo Date: Sun, 20 Jul 2014 17:40:13 +0100 Subject: [PATCH] Add touch_msg() API Signed-off-by: Pedro Melo --- lib/AnyEvent/NSQ/Connection.pm | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/lib/AnyEvent/NSQ/Connection.pm b/lib/AnyEvent/NSQ/Connection.pm index f11b4a6..bc2d82d 100644 --- a/lib/AnyEvent/NSQ/Connection.pm +++ b/lib/AnyEvent/NSQ/Connection.pm @@ -144,6 +144,15 @@ sub requeue_msg { return; } +sub touch_msg { + my ($self, $msg) = @_; + return unless my $hdl = $self->{handle}; + + $hdl->push_write("TOUCH $msg->{message_id}\012"); + + return; +} + sub nop { my ($self, $n) = @_; return unless my $hdl = $self->{handle};