redis.clients.jedis
Class BinaryJedisPubSub

java.lang.Object
  redis.clients.jedis.BinaryJedisPubSub

public abstract class BinaryJedisPubSub
extends Object

Constructor Summary

BinaryJedisPubSub()

Method Summary

int	getSubscribedChannels()
boolean	isSubscribed()
abstract void	onMessage(byte[] channel, byte[] message)
abstract void	onPMessage(byte[] pattern, byte[] channel, byte[] message)
abstract void	onPSubscribe(byte[] pattern, int subscribedChannels)
abstract void	onPUnsubscribe(byte[] pattern, int subscribedChannels)
abstract void	onSubscribe(byte[] channel, int subscribedChannels)
abstract void	onUnsubscribe(byte[] channel, int subscribedChannels)
void	proceed(Client client, byte[]... channels)
void	proceedWithPatterns(Client client, byte[]... patterns)
void	psubscribe(byte[]... patterns)
void	punsubscribe()
void	punsubscribe(byte[]... patterns)
void	subscribe(byte[]... channels)
void	unsubscribe()
void	unsubscribe(byte[]... channels)

Methods inherited from class java.lang.Object

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

Constructor Detail

BinaryJedisPubSub

public BinaryJedisPubSub()

Method Detail

onMessage

public abstract void onMessage(byte[] channel,
                               byte[] message)

onPMessage

public abstract void onPMessage(byte[] pattern,
                                byte[] channel,
                                byte[] message)

onSubscribe

public abstract void onSubscribe(byte[] channel,
                                 int subscribedChannels)

onUnsubscribe

public abstract void onUnsubscribe(byte[] channel,
                                   int subscribedChannels)

onPUnsubscribe

public abstract void onPUnsubscribe(byte[] pattern,
                                    int subscribedChannels)

onPSubscribe

public abstract void onPSubscribe(byte[] pattern,
                                  int subscribedChannels)

unsubscribe

public void unsubscribe()

unsubscribe

public void unsubscribe(byte[]... channels)

subscribe

public void subscribe(byte[]... channels)

psubscribe

public void psubscribe(byte[]... patterns)

punsubscribe

public void punsubscribe()

punsubscribe

public void punsubscribe(byte[]... patterns)

isSubscribed

public boolean isSubscribed()

proceedWithPatterns

public void proceedWithPatterns(Client client,
                                byte[]... patterns)

proceed

public void proceed(Client client,
                    byte[]... channels)

getSubscribedChannels

public int getSubscribedChannels()