NAME
Message::Passing::Input::Redis - A Redis consumer for Message::Passing
SYNOPSIS
$ message-passing --output STDOUT --input Redis --input_options '{"topics":["foo"],"server":"127.0.0.1:6379"}'
DESCRIPTION
A simple subscriber a Redis PubSub topic
ATTRIBUTES
server
The hostname and port number of the Redis server. Defaults to 127.0.0.1:6379
.
topics
A list of topics to consume messages from.
These topic names are matched exactly.
ptopics
A list of pattern topics to consume messages from.
These topic names can wildcard match, so for example prefix1.*
will match topics prefix1.foo
and prefix1.bar
.
METHODS
connected
Called by Message::Passing::Redis::ConnectionManager to indicate a connection to the Redis server has been made.
Causes the subscription to the topic(s) to be started
disconnect
Called by Message::Passing::Redis::ConnectionManager to indicate a connection to the Redis server has failed.