services.moleculer.util.redis

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 services.moleculer.util.redis.AbstractRedisClient

password, resources, secure, urls

Constructor Summary

Constructors

Constructor and Description
RedisPubSubClient(java.lang.String[] urls, java.lang.String password, boolean secure, java.util.concurrent.ExecutorService executor, com.lambdaworks.redis.event.EventBus eventBus, com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]> listener)

Method Summary

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

Methods inherited from class services.moleculer.util.redis.AbstractRedisClient

parseURLs

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisPubSubClient

public RedisPubSubClient(java.lang.String[] urls,
                         java.lang.String password,
                         boolean secure,
                         java.util.concurrent.ExecutorService executor,
                         com.lambdaworks.redis.event.EventBus eventBus,
                         com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]> listener)

Method Detail

connect

public final void connect()

Overrides:

connect in class AbstractRedisClient

subscribe

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

publish

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

disconnect

public final io.datatree.Promise disconnect()

Overrides:

disconnect in class AbstractRedisClient