Package app.ductape.sdk.brokers.utils.providers

Class RedisService

java.lang.Object

app.ductape.sdk.brokers.utils.providers.RedisService

All Implemented Interfaces:

BrokerTypes.IMessageBrokerService

public final class RedisService
extends Object
implements BrokerTypes.IMessageBrokerService

Redis provider runtime parity using lettuce (already a project dependency).

Constructor Summary

Constructors

Constructor	Description
RedisService(Map<String,Object> config)

Method Summary

Modifier and Type	Method	Description
void	connect()
void	disconnect()
void	publish(String topic, Map<String,Object> message)
void	subscribe(String topic, BrokerTypes.MessageCallback callback)

Methods inherited from class java.lang.Object

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

Constructor Details

RedisService

public RedisService(Map<String,Object> config)

Method Details

connect

public void connect()

Specified by:

connect in interface BrokerTypes.IMessageBrokerService

publish

public void publish(String topic,
 Map<String,Object> message)

Specified by:

publish in interface BrokerTypes.IMessageBrokerService

subscribe

public void subscribe(String topic,
 BrokerTypes.MessageCallback callback)

Specified by:

subscribe in interface BrokerTypes.IMessageBrokerService

disconnect

public void disconnect()

Specified by:

disconnect in interface BrokerTypes.IMessageBrokerService