Class RedisTransport

java.lang.Object

com.iantapply.orchestra.adapter.redis.RedisTransport

All Implemented Interfaces:

NetworkTransport, AutoCloseable

public final class RedisTransport
extends Object
implements NetworkTransport

Redis Pub/Sub transport with daemon subscription threads and reconnect handling.

Nested Class Summary

Nested classes/interfaces inherited from interface NetworkTransport

NetworkTransport.Subscription

Constructor Summary

Constructors

Constructor	Description
RedisTransport(URI uri, String namespace)	Creates a Redis Pub/Sub transport.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes all subscriptions and rejects new work.
void	publish(String channel, byte[] payload)	Publishes one binary message.
NetworkTransport.Subscription	subscribe(String channel, Consumer<byte[]> listener)	Subscribes to a logical channel.

Methods inherited from class Object

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

Constructor Details

RedisTransport

public RedisTransport(URI uri,
 String namespace)

Creates a Redis Pub/Sub transport.

Parameters:

uri - Redis URI, optionally containing credentials and database number

namespace - prefix applied to logical channels

Method Details

publish

public void publish(String channel,
 byte[] payload)

Description copied from interface: NetworkTransport

Publishes one binary message.

Specified by:

publish in interface NetworkTransport

Parameters:

channel - logical channel name

payload - immutable message bytes for the duration of the call

subscribe

public NetworkTransport.Subscription subscribe(String channel,
 Consumer<byte[]> listener)

Description copied from interface: NetworkTransport

Subscribes to a logical channel.

Specified by:

subscribe in interface NetworkTransport

Parameters:

channel - logical channel name

listener - message callback

Returns:

subscription handle

close

public void close()

Description copied from interface: NetworkTransport

Closes all subscriptions and rejects new work.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface NetworkTransport