Class RedisPubSubClient

java.lang.Object

services.moleculer.util.redis.AbstractRedisClient

services.moleculer.util.redis.RedisPubSubClient

public final class RedisPubSubClient
extends AbstractRedisClient

Promise-based pub/sub Redis client.

Field Summary

Fields inherited from class AbstractRedisClient

password, resources, secure, urls

Constructor Summary

Constructors

Constructor	Description
RedisPubSubClient(String[] urls, String password, boolean secure, ExecutorService executor, io.lettuce.core.event.EventBus eventBus, io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]> listener)

Method Summary

Modifier and Type	Method	Description
final void	connect()
final io.datatree.Promise	disconnect()
final void	publish(String channel, byte[] message)
final io.datatree.Promise	subscribe(String channel)

Methods inherited from class AbstractRedisClient

parseURLs

Methods inherited from class Object

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

Constructor Details

RedisPubSubClient

public RedisPubSubClient(String[] urls,
 String password,
 boolean secure,
 ExecutorService executor,
 io.lettuce.core.event.EventBus eventBus,
 io.lettuce.core.pubsub.RedisPubSubListener<byte[],byte[]> listener)

Method Details

connect

public final void connect()

Overrides:

connect in class AbstractRedisClient

subscribe

public final io.datatree.Promise subscribe(String channel)

publish

public final void publish(String channel,
 byte[] message)

disconnect

public final io.datatree.Promise disconnect()

Overrides:

disconnect in class AbstractRedisClient