From 3e54c101f4914e53f720be7b58cc613005ce21af Mon Sep 17 00:00:00 2001 From: Pedro Melo Date: Sun, 20 Jul 2014 19:50:14 +0100 Subject: [PATCH] Tidy Signed-off-by: Pedro Melo --- examples/consumer.pl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/examples/consumer.pl b/examples/consumer.pl index 838c394..999f2e9 100755 --- a/examples/consumer.pl +++ b/examples/consumer.pl @@ -19,8 +19,8 @@ my $r = AnyEvent::NSQ::Reader->new( nsqd_tcp_addresses => '127.0.0.1', client_id => "${channel}_consumer/pid_$$", -# message_cb => sub {print STDERR "$c: $_[1]{message}\n";$c++; return}, ## return undef => mark_as_done_msg() - message_cb => sub {return}, ## return undef => mark_as_done_msg() +# message_cb => sub { print STDERR "$c: $_[1]{message}\n"; $c++; return }, ## return undef => mark_as_done_msg() + message_cb => sub {return}, ## return undef => mark_as_done_msg() error_cb => sub { warn "$_[1]\n" }, disconnect_cb => sub { warn "Got disconnected... exiting...\n"; $cv->send },