server/io.spine.server.integration/AbstractChannelObserver

AbstractChannelObserver

public abstract class AbstractChannelObserver

Base routines for the addObserver subscriber observers.

Constructors

AbstractChannelObserver

protected void AbstractChannelObserver(BoundedContextName boundedContextName, Class<? extends Message> messageClass)

Functions

public boolean equals(Object o)

protected abstract void handle(ExternalMessage message)

Handles the message received via this channel.

public int hashCode()

public void onCompleted()

public void onError(Throwable t)

public final void onNext(ExternalMessage message)