diff --git a/examples/consumer.pl b/examples/consumer.pl index 09cd5d6..7d09c40 100755 --- a/examples/consumer.pl +++ b/examples/consumer.pl @@ -22,7 +22,7 @@ my $r = AnyEvent::NSQ::Reader->new( # 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 "FATAL: got error message '$_[1]', exiting...\n"; $cv->send }, + error_cb => sub { warn "$_[1] --- exiting...\n"; $cv->send }, ); $cv->recv;