6 our ( $redis_host, $redis_port );
9 my $channel = $ARGV[0] || die "usage: $0 channel\n";
11 my $sub = AnyEvent::Redis->new( host => $redis_host, port => $redis_port );
13 my $sub_cv = $sub->psubscribe($channel, sub {
14 my($message, $chan) = @_;
15 warn "# $chan | $message\n";
18 AnyEvent->condvar->recv;