BinaryJedisPubSub

java.lang.Object

redis.clients.jedis.BinaryJedisPubSub

public abstract class BinaryJedisPubSub extends Object

Field Summary

Fields

Modifier and Type

Field

Description

private Connection

client

private int

subscribedChannels
Constructor Summary

Constructors

Constructor

Description

BinaryJedisPubSub()
Method Summary

Modifier and Type

Method

Description

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(Connection client, byte[]... channels)

void

proceedWithPatterns(Connection client, byte[]... patterns)

private void

process()

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

Field Details
- subscribedChannels
  
  private int subscribedChannels
- client
  
  private Connection client
Constructor Details
- BinaryJedisPubSub
  
  public BinaryJedisPubSub()
Method Details
- 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(Connection client, byte[]... patterns)
- proceed
  
  public void proceed(Connection client, byte[]... channels)
- process
  
  private void process()
- getSubscribedChannels
  
  public int getSubscribedChannels()