scripts/mqr-subscribe.pl

   1 #!/usr/bin/perl
   2 use warnings;
   3 use strict;
   4 use AnyEvent::Redis;
   5
   6 our ( $redis_host, $redis_port );
   7 require 'config.pl';
   8
   9 my $channel = $ARGV[0] || die "usage: $0 channel\n";
  10
  11 my $sub = AnyEvent::Redis->new( host => $redis_host, port => $redis_port );
  12
  13 my $sub_cv = $sub->psubscribe($channel, sub {
  14         my($message, $chan) = @_;
  15         warn "# $chan | $message\n";
  16 });
  17
  18 AnyEvent->condvar->recv;
  19