Package com.blackrook.redis.event

Class RedisSubscriptionDebugListener

java.lang.Object

com.blackrook.redis.event.RedisSubscriptionDebugListener

All Implemented Interfaces:

RedisSubscriptionListener

public class RedisSubscriptionDebugListener
extends Object
implements RedisSubscriptionListener

An adapter class for RedisSubscriptionListener that prints messages to a PrintStream when events are heard.

Author:

Matthew Tropiano

Constructor Summary

Constructors

Constructor	Description
RedisSubscriptionDebugListener()	Creates a listener that dumps to System.out.
RedisSubscriptionDebugListener(PrintStream out)	Creates a listener.

Method Summary

Modifier and Type	Method	Description
void	onMessageReceive(String channel, String message)	Called when this subscription connection receives a message from a channel.
void	onPatternMessageReceive(String channelPattern, String channel, String message)	Called when this subscription connection receives a message from a channel.
void	onPatternSubscribe(String channelPattern, long channelTotal)	Called when this subscription connection subscribes to a set of channels via a pattern.
void	onPatternUnsubscribe(String channelPattern, long channelTotal)	Called when this subscription connection unsubscribes from a set of channels via a pattern.
void	onSubscribe(String channelName, long channelTotal)	Called when this subscription connection subscribes to a channel.
void	onUnsubscribe(String channelName, long channelTotal)	Called when this subscription connection unsubscribes from a channel.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisSubscriptionDebugListener

public RedisSubscriptionDebugListener()

Creates a listener that dumps to System.out.

RedisSubscriptionDebugListener

public RedisSubscriptionDebugListener(PrintStream out)

Creates a listener.

Parameters:

out - the PrintStream to dump output to.

Method Detail

onSubscribe

public void onSubscribe(String channelName,
                        long channelTotal)

Description copied from interface: RedisSubscriptionListener

Called when this subscription connection subscribes to a channel.

Specified by:

onSubscribe in interface RedisSubscriptionListener

Parameters:

channelName - the subscribed channel.

channelTotal - the total number of channels that this subscriber is subscribed to.

onUnsubscribe

public void onUnsubscribe(String channelName,
                          long channelTotal)

Description copied from interface: RedisSubscriptionListener

Called when this subscription connection unsubscribes from a channel.

Specified by:

onUnsubscribe in interface RedisSubscriptionListener

Parameters:

channelName - the channel that this unsubscribed from.

channelTotal - the total number of channels that this subscriber is subscribed to.

onPatternSubscribe

public void onPatternSubscribe(String channelPattern,
                               long channelTotal)

Description copied from interface: RedisSubscriptionListener

Called when this subscription connection subscribes to a set of channels via a pattern.

Specified by:

onPatternSubscribe in interface RedisSubscriptionListener

Parameters:

channelPattern - the channel pattern that this subscribed to.

channelTotal - the total number of channels that this subscriber is subscribed to.

onPatternUnsubscribe

public void onPatternUnsubscribe(String channelPattern,
                                 long channelTotal)

Description copied from interface: RedisSubscriptionListener

Called when this subscription connection unsubscribes from a set of channels via a pattern.

Specified by:

onPatternUnsubscribe in interface RedisSubscriptionListener

Parameters:

channelPattern - the channel pattern that this unsubscribed from.

channelTotal - the total number of channels that this subscriber is subscribed to.

onMessageReceive

public void onMessageReceive(String channel,
                             String message)

Description copied from interface: RedisSubscriptionListener

Called when this subscription connection receives a message from a channel.

Specified by:

onMessageReceive in interface RedisSubscriptionListener

Parameters:

channel - the channel that the message came from.

message - the message received.

onPatternMessageReceive

public void onPatternMessageReceive(String channelPattern,
                                    String channel,
                                    String message)

Description copied from interface: RedisSubscriptionListener

Called when this subscription connection receives a message from a channel.

Specified by:

onPatternMessageReceive in interface RedisSubscriptionListener

Parameters:

channelPattern - the channel pattern that was matched.

channel - the channel that the message came from.

message - the message received.