scripts/mqr-track.pl

   1 #!/usr/bin/perl
   2 use warnings;
   3 use strict;
   4 use AnyEvent::Redis;
   5 use Data::Dump qw(dump);
   6
   7 my $sub = AnyEvent::Redis->new( host => $ENV{REDIS_HOST}, port => $ENV{REDIS_PORT} );
   8
   9 my $track;
  10
  11 my $sub_cv = $sub->psubscribe('*', sub {
  12         my($message, $chan) = @_;
  13         warn "$chan | $message\n";
  14         if ( $message =~ m/^!track\s*(.+)/ ) {
  15                 $track->{$chan}->{$1}++;
  16                 warn "# track ",dump($track);
  17         }
  18 });
  19
  20 AnyEvent->condvar->recv;
  21