lib/MQR/Redis.pm

   1 package MQR::Redis;
   2
   3 use AnyEvent::Redis;
   4 use Carp qw(confess);
   5 use Data::Dump qw(dump);
   6
   7 sub redis {
   8         AnyEvent::Redis->new( host => $ENV{REDIS_HOST}, port => $ENV{REDIS_PORT}, on_error => sub { confess @_ } );
   9 }
  10
  11 sub publish {
  12         my ( $channel, $body ) = @_;
  13         $channel = join(' ', @$channel) if ref $channel eq 'ARRAY';
  14         my $pub = redis;
  15         $pub->publish( $channel, $body );
  16         warn ">>>> ",dump($channel, $body);
  17 }
  18
  19 1;