redis.clients.jedis

类 BinaryJedisPubSub

java.lang.Object

redis.clients.jedis.BinaryJedisPubSub

public abstract class BinaryJedisPubSub
extends java.lang.Object

构造器概要

构造器

构造器和说明
BinaryJedisPubSub()

方法概要

限定符和类型	方法和说明
int	getSubscribedChannels()
boolean	isSubscribed()
void	onMessage(byte[] channel, byte[] message)
void	onPMessage(byte[] pattern, byte[] channel, byte[] message)
void	onPong(byte[] pattern)
void	onPSubscribe(byte[] pattern, int subscribedChannels)
void	onPUnsubscribe(byte[] pattern, int subscribedChannels)
void	onSubscribe(byte[] channel, int subscribedChannels)
void	onUnsubscribe(byte[] channel, int subscribedChannels)
void	ping()
void	ping(byte[] argument)
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)

从类继承的方法 java.lang.Object

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

构造器详细资料

BinaryJedisPubSub

public BinaryJedisPubSub()

方法详细资料

onMessage

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

onPMessage

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

onSubscribe

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

onUnsubscribe

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

onPUnsubscribe

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

onPSubscribe

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

onPong

public void onPong(byte[] pattern)

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)

ping

public void ping()

ping

public void ping(byte[] argument)

isSubscribed

public boolean isSubscribed()

proceedWithPatterns

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

proceed

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

getSubscribedChannels

public int getSubscribedChannels()