redis.clients.jedis

Class JedisPubSub

java.lang.Object

redis.clients.jedis.JedisPubSub

public abstract class JedisPubSub
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
private Client	client
private int	subscribedChannels

Constructor Summary

Constructors

Constructor and Description
JedisPubSub()

Method Summary

Modifier and Type	Method and Description
int	getSubscribedChannels()
boolean	isSubscribed()
void	onMessage(java.lang.String channel, java.lang.String message)
void	onPMessage(java.lang.String pattern, java.lang.String channel, java.lang.String message)
void	onPSubscribe(java.lang.String pattern, int subscribedChannels)
void	onPUnsubscribe(java.lang.String pattern, int subscribedChannels)
void	onSubscribe(java.lang.String channel, int subscribedChannels)
void	onUnsubscribe(java.lang.String channel, int subscribedChannels)
void	proceed(Client client, java.lang.String... channels)
void	proceedWithPatterns(Client client, java.lang.String... patterns)
private void	process(Client client)
void	psubscribe(java.lang.String... patterns)
void	punsubscribe()
void	punsubscribe(java.lang.String... patterns)
void	subscribe(java.lang.String... channels)
void	unsubscribe()
void	unsubscribe(java.lang.String... channels)

Methods inherited from class java.lang.Object

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

Field Detail

subscribedChannels

private int subscribedChannels

client

private volatile Client client

Constructor Detail

JedisPubSub

public JedisPubSub()

Method Detail

onMessage

public void onMessage(java.lang.String channel,
                      java.lang.String message)

onPMessage

public void onPMessage(java.lang.String pattern,
                       java.lang.String channel,
                       java.lang.String message)

onSubscribe

public void onSubscribe(java.lang.String channel,
                        int subscribedChannels)

onUnsubscribe

public void onUnsubscribe(java.lang.String channel,
                          int subscribedChannels)

onPUnsubscribe

public void onPUnsubscribe(java.lang.String pattern,
                           int subscribedChannels)

onPSubscribe

public void onPSubscribe(java.lang.String pattern,
                         int subscribedChannels)

unsubscribe

public void unsubscribe()

unsubscribe

public void unsubscribe(java.lang.String... channels)

subscribe

public void subscribe(java.lang.String... channels)

psubscribe

public void psubscribe(java.lang.String... patterns)

punsubscribe

public void punsubscribe()

punsubscribe

public void punsubscribe(java.lang.String... patterns)

isSubscribed

public boolean isSubscribed()

proceedWithPatterns

public void proceedWithPatterns(Client client,
                                java.lang.String... patterns)

proceed

public void proceed(Client client,
                    java.lang.String... channels)

process

private void process(Client client)

getSubscribedChannels

public int getSubscribedChannels()