io.spine.client

Interface ConsumerErrorHandler<M extends com.google.protobuf.Message>

Type Parameters:

M - the type of messages delivered to consumers

All Superinterfaces:

java.util.function.BiConsumer<io.spine.client.MessageConsumer<M,?>,java.lang.Throwable>

@FunctionalInterface
public interface ConsumerErrorHandler<M extends com.google.protobuf.Message>
extends java.util.function.BiConsumer<io.spine.client.MessageConsumer<M,?>,java.lang.Throwable>

Functional interface for handlers of errors caused by consumers of messages.

See Also:

SubscribingRequest.onConsumingError(ConsumerErrorHandler)

Method Summary

Modifier and Type	Method and Description
static <M extends com.google.protobuf.Message> ConsumerErrorHandler<M>	logError(com.google.common.flogger.FluentLogger logger, java.lang.String messageFormat, java.lang.Class<? extends com.google.protobuf.Message> type) Obtains the handler which logs the fact of the error using the severe level of the passed logger.

Methods inherited from interface java.util.function.BiConsumer

accept, andThen

Method Detail

logError

static <M extends com.google.protobuf.Message> ConsumerErrorHandler<M> logError(com.google.common.flogger.FluentLogger logger,
                                                                                java.lang.String messageFormat,
                                                                                java.lang.Class<? extends com.google.protobuf.Message> type)

Obtains the handler which logs the fact of the error using the severe level of the passed logger.

Type Parameters:

M - the type of the messages delivered to the consumer

Parameters:

logger - the instance of the logger to use for reporting the error

messageFormat - the formatting message where the first parameter is the consumer which caused the error, and the second parameter is the type of the message which caused the error

Returns:

the logging error handler