6 my $channel = $ARGV[0] || die "usage: $0 channel\n";
8 my $sub = AnyEvent::Redis->new( host => $ENV{REDIS_HOST}, port => $ENV{REDIS_PORT} );
10 my $sub_cv = $sub->psubscribe($channel, sub {
11 my($message, $chan) = @_;
12 warn "# $chan | $message\n";
15 AnyEvent->condvar->recv;