services.moleculer.transporter

Class RedisTransporter

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.transporter.Transporter

services.moleculer.transporter.RedisTransporter

All Implemented Interfaces:

com.lambdaworks.redis.event.EventBus, com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>, MetricConstants, MoleculerLifecycle

public class RedisTransporter
extends Transporter
implements com.lambdaworks.redis.event.EventBus, com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>

Redis Transporter. Redis is an open source (BSD licensed), in-memory data structure store, used as a database, cache and message broker (website: https://redis.io). Usage:

 ServiceBroker broker = ServiceBroker.builder().nodeID("node1")
 .transporter(new RedisTransporter("localhost")).build();
 

Required dependency:

// https://mvnrepository.com/artifact/biz.paluch.redis/lettuce
compile group: 'biz.paluch.redis', name: 'lettuce', version: '4.5.0.Final'

See Also:

TcpTransporter, NatsTransporter, NatsStreamingTransporter, MqttTransporter, JmsTransporter, KafkaTransporter, AmqpTransporter

Field Summary

Fields

Modifier and Type	Field and Description
protected RedisPubSubClient	clientPub
protected RedisPubSubClient	clientSub
protected java.lang.String	password
protected boolean	secure
protected java.util.concurrent.atomic.AtomicInteger	status
protected static int	STATUS_CONNECTED
protected static int	STATUS_CONNECTING_1
protected static int	STATUS_CONNECTING_2
protected static int	STATUS_DISCONNECTED
protected static int	STATUS_DISCONNECTING
protected java.lang.String[]	urls

Fields inherited from class services.moleculer.transporter.Transporter

checkTimeoutTimer, counterTransporterPacketsReceivedBytes, counterTransporterPacketsReceivedTotal, counterTransporterPacketsSentBytes, counterTransporterPacketsSentTotal, debug, debugHeartbeats, disconnectChannel, discoverBroadcastChannel, discoverChannel, eventbus, eventChannel, executor, gaugeTransitConnected, heartbeatChannel, heartbeatInterval, heartbeatTimeout, heartBeatTimer, infoBroadcastChannel, infoChannel, infoScheduled, infoScheduledAt, instanceID, lastReceivedMessageAt, metrics, monitor, namespace, nodeID, nodes, offlineTimeout, PACKET_DISCONNECT, PACKET_DISCOVER, PACKET_EVENT, PACKET_HEARTBEAT, PACKET_INFO, PACKET_PING, PACKET_PONG, PACKET_REQUEST, PACKET_RESPONSE, pingChannel, pongChannel, preferHostname, prefix, protocolVersion, registry, requestChannel, responseChannel, scheduler, serializer, serviceInvoker, subscriptionTimeout, uidGenerator, usingJsonSerializer

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Fields inherited from interface services.moleculer.metrics.MetricConstants

MOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC

Constructor Summary

Constructors

Constructor and Description
RedisTransporter()
RedisTransporter(java.lang.String... urls)
RedisTransporter(java.lang.String password, boolean secure, java.lang.String... urls)

Method Summary

Modifier and Type	Method and Description
void	connect()
protected io.datatree.Promise	disconnect()
protected void	error(java.lang.Throwable cause) Any I/O error occurred.
rx.Observable<com.lambdaworks.redis.event.Event>	get()
java.lang.String	getPassword()
java.lang.String[]	getUrls()
boolean	isSecure()
void	message(byte[] channel, byte[] message)
void	message(byte[] pattern, byte[] channel, byte[] message)
void	psubscribed(byte[] pattern, long count)
void	publish(com.lambdaworks.redis.event.Event event)
void	publish(java.lang.String channel, io.datatree.Tree message)
void	punsubscribed(byte[] pattern, long count)
protected void	reconnect()
void	setPassword(java.lang.String password)
void	setSecure(boolean secure)
void	setUrls(java.lang.String[] urls)
void	stopped() Closes transporter.
io.datatree.Promise	subscribe(java.lang.String channel)
void	subscribed(byte[] channel, long count)
protected void	unableToConnect(java.lang.Exception cause)
void	unsubscribed(byte[] channel, long count)

Methods inherited from class services.moleculer.transporter.Transporter

broadcastInfoPacket, broadcastNodeConnected, broadcastNodeDisconnected, broadcastNodeUpdated, broadcastTransporterConnected, broadcastTransporterDisconnected, channel, checkTimeouts, connected, connected, createPingPacket, getAddress, getAllNodeIDs, getCpuUsage, getDescriptor, getHeartbeatInterval, getHeartbeatTimeout, getInstanceID, getLastHeartbeatTime, getNamespace, getOfflineTimeout, getPrefix, getSerializer, getSubscriptionTimeout, isDebug, isDebugHeartbeats, isOnline, isPreferHostname, processReceivedMessage, processReceivedMessage, publish, received, scheduleInfoPacket, sendClosePacket, sendDataPacket, sendDisconnectPacket, sendDiscoverPacket, sendErrorPacket, sendEventPacket, sendHeartbeatPacket, sendInfoPacket, sendPongPacket, sendRequestPacket, setDebug, setDebugHeartbeats, setHeartbeatInterval, setHeartbeatTimeout, setNamespace, setOfflineTimeout, setPreferHostname, setPrefix, setSerializer, setSubscriptionTimeout, started, subscribe, updateNodeInfo

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

STATUS_DISCONNECTING

protected static final int STATUS_DISCONNECTING

See Also:

Constant Field Values

STATUS_DISCONNECTED

protected static final int STATUS_DISCONNECTED

See Also:

Constant Field Values

STATUS_CONNECTING_1

protected static final int STATUS_CONNECTING_1

See Also:

Constant Field Values

STATUS_CONNECTING_2

protected static final int STATUS_CONNECTING_2

See Also:

Constant Field Values

STATUS_CONNECTED

protected static final int STATUS_CONNECTED

See Also:

Constant Field Values

status

protected final java.util.concurrent.atomic.AtomicInteger status

password

protected java.lang.String password

secure

protected boolean secure

urls

protected java.lang.String[] urls

clientSub

protected RedisPubSubClient clientSub

clientPub

protected RedisPubSubClient clientPub

Constructor Detail

RedisTransporter

public RedisTransporter()

RedisTransporter

public RedisTransporter(java.lang.String... urls)

RedisTransporter

public RedisTransporter(java.lang.String password,
                        boolean secure,
                        java.lang.String... urls)

Method Detail

connect

public void connect()

Specified by:

connect in class Transporter

unableToConnect

protected void unableToConnect(java.lang.Exception cause)

disconnect

protected io.datatree.Promise disconnect()

reconnect

protected void reconnect()

error

protected void error(java.lang.Throwable cause)

Description copied from class: Transporter

Any I/O error occurred. Implementation-specific error handling goes here (reconnection, etc.).

Overrides:

error in class Transporter

Parameters:

cause - I/O error

stopped

public void stopped()

Closes transporter.

Specified by:

stopped in interface MoleculerLifecycle

Overrides:

stopped in class Transporter

subscribe

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

Specified by:

subscribe in class Transporter

publish

public void publish(java.lang.String channel,
                    io.datatree.Tree message)

Specified by:

publish in class Transporter

message

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

Specified by:

message in interface com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>

message

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

Specified by:

message in interface com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>

subscribed

public void subscribed(byte[] channel,
                       long count)

Specified by:

subscribed in interface com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>

psubscribed

public void psubscribed(byte[] pattern,
                        long count)

Specified by:

psubscribed in interface com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>

unsubscribed

public void unsubscribed(byte[] channel,
                         long count)

Specified by:

unsubscribed in interface com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>

punsubscribed

public void punsubscribed(byte[] pattern,
                          long count)

Specified by:

punsubscribed in interface com.lambdaworks.redis.pubsub.RedisPubSubListener<byte[],byte[]>

publish

public void publish(com.lambdaworks.redis.event.Event event)

Specified by:

publish in interface com.lambdaworks.redis.event.EventBus

get

public rx.Observable<com.lambdaworks.redis.event.Event> get()

Specified by:

get in interface com.lambdaworks.redis.event.EventBus

getUrls

public java.lang.String[] getUrls()

setUrls

public void setUrls(java.lang.String[] urls)

getPassword

public java.lang.String getPassword()

setPassword

public void setPassword(java.lang.String password)

isSecure

public boolean isSecure()

setSecure

public void setSecure(boolean secure)