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

Make consumer.pl trap SIGINT and SIGTERM, disconnect cleanly

Browse Source 
Signed-off-by: Pedro Melo <melo@simplicidade.org>
This commit is contained in:
Pedro Melo
2014-07-21 05:20:45 +01:00
parent cfa7a7b4a5
commit b69bd4a19b
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
examples/consumer.pl
View File

@@ -29,10 +29,13 @@ my $r = AnyEvent::NSQ::Reader->new(
message_cb => sub { $t++; $message_cb->(@_, $t) }, message_cb => sub { $t++; $message_cb->(@_, $t) },
error_cb => sub { warn "$_[1]\n" if $verbose }, error_cb => sub { warn "$_[1]\n" if $verbose },
disconnect_cb => sub { warn "Got disconnected after $t total messages... exiting...\n" if $verbose; $cv->send }, disconnect_cb => sub { warn "Disconnected after $t total messages... exiting...\n" if $verbose; $cv->send },
); );
my $term_sgn = AE::signal TERM => sub { $r->disconnect };
my $int_sgn = AE::signal INT => sub { $r->disconnect };
$cv->recv; $cv->recv;