Class RedisProxyListener

java.lang.Object

net.flectone.pulse.listener.proxy.RedisProxyListener

All Implemented Interfaces:

io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>

public class RedisProxyListener
extends Object
implements io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>

Constructor Summary

Constructors

Constructor	Description
RedisProxyListener(RedisProxy redisProxySender, ProxyMessageProcessor proxyMessageProcessor)

Method Summary

Modifier and Type	Method	Description
void	message(byte[] channel, byte[] message)
void	message(byte[] bytes, byte[] k1, byte[] bytes2)
void	psubscribed(byte[] bytes, long l)
void	punsubscribed(byte[] bytes, long l)
void	subscribed(byte[] bytes, long l)
void	unsubscribed(byte[] bytes, long l)

Methods inherited from class Object

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

Methods inherited from interface io.lettuce.core.pubsub.RedisPubSubListener

smessage, ssubscribed, sunsubscribed

Constructor Details

RedisProxyListener

@Inject
public RedisProxyListener(RedisProxy redisProxySender,
 ProxyMessageProcessor proxyMessageProcessor)

Method Details

message

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

Specified by:

message in interface io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>

message

public void message(byte[] bytes,
 byte[] k1,
 byte[] bytes2)

Specified by:

message in interface io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>

subscribed

public void subscribed(byte[] bytes,
 long l)

Specified by:

subscribed in interface io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>

psubscribed

public void psubscribed(byte[] bytes,
 long l)

Specified by:

psubscribed in interface io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>

unsubscribed

public void unsubscribed(byte[] bytes,
 long l)

Specified by:

unsubscribed in interface io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>

punsubscribed

public void punsubscribed(byte[] bytes,
 long l)

Specified by:

punsubscribed in interface io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]>