PublisherHub

public class PublisherHub extends ChannelHub<C>

The hub of Publishers.

Creates and manages the existing publisher channels born in the given TransportFactory.

Constructors

public void PublisherHub(TransportFactory transportFactory)

protected Publisher newChannel(ChannelId channelId)

Creates a new channel under the specified ID.

public void close()

public abstract 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()