NAME

Mojo::Redis::Subscription - Result of Mojo::Redis->subscribe()

SYNOPSIS

You can create a Mojo::Redis::Subscription object in two ways:

Either from Mojo::Redis:

  use Mojo::Redis;
  $r = Mojo::Redis->new;
  $s = $r->subscribe('foo'); # does also ->connect()
  print @{ $s->channels } # print "foo";

...or from Mojo::Redis::Subscription:

  use Mojo::Redis::Subscription;
  my $s = Mojo::Redis::Subscription->new;
  $s->channels(['foo']);
  $s->connect;

Either way you need to subscribe to an event:

  $s->on(message => sub {
      my($s, $message, $channel) = @_;
  });

  Mojo::IOLoop->start;

EVENTS

message

  $self->on(message => sub { my($self, $message, $channel) = @_; ... });

This event receive the messages sent over the channel.

data

  $self->on(data => sub { my($self, $data) = @_; ... });

This event receive all data sent over the channel. Example:

  0: ['subscribe', 'first_channel_name', 1];
  1: ['message', 'first_channel_name','yay!']

ATTRIBUTES

channels

Holds an array ref of channel names which this object subscribe to.

type

Describes the sort of subscription this object is using: subscribe or psubscribe.

METHODS

connect

Used to connect to the redis server and start subscribing to the "channels". This is called automatically from "subscribe" in Mojo::Redis.

disconnect

Will remove the connection to the redis server. This also happen when the object goes out of scope.

AUTHOR

Jan Henning Thorsen - jhthorsen@cpan.org