The message already has most of the important stuff
Signed-off-by: Pedro Melo <melo@simplicidade.org>
This commit is contained in:
@@ -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;
|
||||
|
||||
Reference in New Issue
Block a user