public final class

RedisPubSubListener

extends BinaryJedisPubSub
java.lang.Object
   ↳ redis.clients.jedis.BinaryJedisPubSub
     ↳ org.mule.module.redis.RedisPubSubListener

Summary

Fields
private static final Log LOGGER
private final SourceCallback callback
[Expand]
Inherited Fields
From class redis.clients.jedis.BinaryJedisPubSub
Public Constructors
RedisPubSubListener(SourceCallback callback)
Public Methods
void onMessage(byte[] channel, byte[] message)
void onPMessage(byte[] pattern, byte[] channel, byte[] message)
void onPSubscribe(byte[] pattern, int subscribedChannels)
void onPUnsubscribe(byte[] pattern, int subscribedChannels)
void onSubscribe(byte[] channel, int subscribedChannels)
void onUnsubscribe(byte[] channel, int subscribedChannels)
[Expand]
Inherited Methods
From class redis.clients.jedis.BinaryJedisPubSub
From class java.lang.Object

Fields

private static final Log LOGGER

private final SourceCallback callback

Public Constructors

public RedisPubSubListener (SourceCallback callback)

Parameters
callback

Public Methods

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

Parameters
channel
message

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

Parameters
pattern
channel
message

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

Parameters
pattern
subscribedChannels

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

Parameters
pattern
subscribedChannels

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

Parameters
channel
subscribedChannels

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

Parameters
channel
subscribedChannels