Class ChannelRouter

java.lang.Object

com.iantapply.relay.core.ChannelRouter

public final class ChannelRouter
extends Object

Maps logical destinations and node roles to namespaced transport channels.

Constructor Summary

Constructors

Constructor	Description
ChannelRouter(String namespace)	Creates a router for one Redis namespace.

Method Summary

Modifier and Type	Method	Description
String	channel(com.iantapply.relay.api.Destination destination)	Resolves the publication channel for a destination.
List<String>	subscriptions(RelayConfig config)	Returns the channels a node must consume for broadcasts, its platform, and its node ID.

Methods inherited from class Object

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

Constructor Details

ChannelRouter

public ChannelRouter(String namespace)

Creates a router for one Redis namespace.

Parameters:

namespace - namespace shared by communicating Relay nodes

Method Details

channel

public String channel(com.iantapply.relay.api.Destination destination)

Resolves the publication channel for a destination.

Parameters:

destination - logical destination

Returns:

transport channel name

subscriptions

public List<String> subscriptions(RelayConfig config)

Returns the channels a node must consume for broadcasts, its platform, and its node ID.

Parameters:

config - local node configuration

Returns:

channel names to subscribe to