public abstract class JedisPubSub
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private Client |
client |
private int |
subscribedChannels |
| Constructor and Description |
|---|
JedisPubSub() |
| 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) |
private int subscribedChannels
private volatile Client client
public void onMessage(java.lang.String channel,
java.lang.String message)
public void onPMessage(java.lang.String pattern,
java.lang.String channel,
java.lang.String message)
public void onSubscribe(java.lang.String channel,
int subscribedChannels)
public void onUnsubscribe(java.lang.String channel,
int subscribedChannels)
public void onPUnsubscribe(java.lang.String pattern,
int subscribedChannels)
public void onPSubscribe(java.lang.String pattern,
int subscribedChannels)
public void unsubscribe()
public void unsubscribe(java.lang.String... channels)
public void subscribe(java.lang.String... channels)
public void psubscribe(java.lang.String... patterns)
public void punsubscribe()
public void punsubscribe(java.lang.String... patterns)
public boolean isSubscribed()
public void proceedWithPatterns(Client client, java.lang.String... patterns)
public void proceed(Client client, java.lang.String... channels)
private void process(Client client)
public int getSubscribedChannels()