ChannelHub

public abstract class ChannelHub<C extends MessageChannel> implements AutoCloseable

The hub of channels grouped in some logical way.

Serves for channel creation and storage-per-ID which in a way makes the hub similar to an entity repository.

Constructors

protected void ChannelHub(TransportFactory transportFactory)

public void close()

Closes the stale channels and removes those from the hub.

public C get(ChannelId channelId)

Obtains a channel from this hub by the given channel ID.

public boolean hasChannel(ChannelId id)

Checks if this channel hub contains a channel with a given ID.

public Set<ChannelId> ids()

protected abstract C newChannel(ChannelId id)

Creates a new channel under the specified ID.