Subscriber

public abstract class Subscriber extends AbstractChannel

Subscriber for messages of a specific type.

There can be many subscribers per message type.

Constructors

protected void Subscriber(ChannelId id)

public void addObserver(StreamObserver<ExternalMessage> observer)

Adds an observer to receive the subscription updates.

protected final void callObservers(ExternalMessage message)

public void close()

public boolean isStale()

Allows to understand whether this channel is stale and can be closed.

public Iterable<StreamObserver<ExternalMessage>> observers()

Obtains current observers registered in this instance of Subscriber which receive the subscription updates.

public void onMessage(ExternalMessage message)

Passes the given message to observers.

public void removeObserver(StreamObserver<ExternalMessage> observer)

Removes an existing observer and disconnects it from this subscription channel.

public static ChannelId channelIdFor(TypeUrl messageType)

Converts the given message type into a ChannelId.

public ChannelId id()

Obtains the channel identifier.

public TypeUrl targetType()

Obtains the type of the messages transferred through this channel.