io.spine.server.transport

Class SubscriberHub

java.lang.Object

io.spine.server.transport.ChannelHub<Subscriber>

io.spine.server.transport.SubscriberHub

All Implemented Interfaces:

java.lang.AutoCloseable

public class SubscriberHub
extends ChannelHub<Subscriber>

The hub of Subscribers.

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

Constructor Summary

Constructors

Constructor and Description
SubscriberHub(TransportFactory transportFactory)

Method Summary

Modifier and Type	Method and Description
protected Subscriber	newChannel(io.spine.server.transport.ChannelId id) Creates a new channel under the specified ID.

Methods inherited from class io.spine.server.transport.ChannelHub

close, closeStaleChannels, get, hasChannel, ids

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriberHub

public SubscriberHub(TransportFactory transportFactory)

Method Detail

newChannel

protected Subscriber newChannel(io.spine.server.transport.ChannelId id)

Description copied from class: ChannelHub

Creates a new channel under the specified ID.

Specified by:

newChannel in class ChannelHub<Subscriber>

Parameters:

id - the ID of the channel to create

Returns:

the created channel.