io.spine.server.integration

Class AbstractChannelObserver

java.lang.Object

io.spine.server.integration.AbstractChannelObserver

All Implemented Interfaces:

io.grpc.stub.StreamObserver<io.spine.server.integration.ExternalMessage>, io.spine.logging.Logging

@SPI
public abstract class AbstractChannelObserver
extends java.lang.Object
implements io.grpc.stub.StreamObserver<io.spine.server.integration.ExternalMessage>, io.spine.logging.Logging

Base routines for the Subscriber.addObserver(StreamObserver) subscriber observers.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractChannelObserver(io.spine.core.BoundedContextName boundedContextName, java.lang.Class<? extends com.google.protobuf.Message> messageClass)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
protected abstract void	handle(io.spine.server.integration.ExternalMessage message) Handles the message received via this channel.
int	hashCode()
void	onCompleted()
void	onError(java.lang.Throwable t)
void	onNext(io.spine.server.integration.ExternalMessage message)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.spine.logging.Logging

_config, _debug, _error, _fine, _finer, _finest, _info, _severe, _trace, _warn, debugLevel, errorLevel, logger, loggerFor

Constructor Detail

AbstractChannelObserver

protected AbstractChannelObserver(io.spine.core.BoundedContextName boundedContextName,
                                  java.lang.Class<? extends com.google.protobuf.Message> messageClass)

Method Detail

handle

protected abstract void handle(io.spine.server.integration.ExternalMessage message)

Handles the message received via this channel.

This behaviour is specific to the particular channel observer implementation.

Parameters:

message - the received message

onError

public void onError(java.lang.Throwable t)

Specified by:

onError in interface io.grpc.stub.StreamObserver<io.spine.server.integration.ExternalMessage>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<io.spine.server.integration.ExternalMessage>

onNext

public final void onNext(io.spine.server.integration.ExternalMessage message)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<io.spine.server.integration.ExternalMessage>

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object