services.moleculer.service

Class DefaultServiceInvoker

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.ServiceInvoker

services.moleculer.service.DefaultServiceInvoker

All Implemented Interfaces:

MetricConstants, MoleculerLifecycle

Direct Known Subclasses:

CircuitBreaker

public class DefaultServiceInvoker
extends ServiceInvoker
implements MetricConstants

Default service invoker with retry logic.

Field Summary

Fields

Modifier and Type	Field and Description
protected Eventbus	eventbus
protected int	maxCallLevel Max call level (for nested calls)
protected Metrics	metrics
protected java.util.function.Predicate<java.lang.Throwable>	retryLogic
protected ServiceRegistry	serviceRegistry
protected UidGenerator	uidGenerator
protected boolean	writeErrorsToLog Write exceptions into the log file

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Fields inherited from interface services.moleculer.metrics.MetricConstants

MOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC

Constructor Summary

Constructors

Constructor and Description
DefaultServiceInvoker()

Method Summary

Modifier and Type	Method and Description
io.datatree.Promise	call(Context ctx)
protected io.datatree.Promise	call(Context ctx, java.lang.String targetID, int remaining)
int	getMaxCallLevel()
java.util.function.Predicate<java.lang.Throwable>	getRetryLogic()
boolean	isWriteErrorsToLog()
protected io.datatree.Promise	retry(Context ctx, java.lang.String targetID, int remaining, java.lang.Throwable cause)
void	setMaxCallLevel(int maxCallLevel)
void	setRetryLogic(java.util.function.Predicate<java.lang.Throwable> retryLogic)
void	setWriteErrorsToLog(boolean writeErrorsToLog)
void	started(ServiceBroker broker)

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName, stopped

Methods inherited from class java.lang.Object

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

Field Detail

writeErrorsToLog

protected boolean writeErrorsToLog

Write exceptions into the log file

maxCallLevel

protected int maxCallLevel

Max call level (for nested calls)

serviceRegistry

protected ServiceRegistry serviceRegistry

eventbus

protected Eventbus eventbus

uidGenerator

protected UidGenerator uidGenerator

metrics

protected Metrics metrics

retryLogic

protected java.util.function.Predicate<java.lang.Throwable> retryLogic

Constructor Detail

DefaultServiceInvoker

public DefaultServiceInvoker()

Method Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class MoleculerComponent

Throws:

java.lang.Exception

call

public io.datatree.Promise call(Context ctx)

Specified by:

call in class ServiceInvoker

call

protected io.datatree.Promise call(Context ctx,
                                   java.lang.String targetID,
                                   int remaining)

retry

protected io.datatree.Promise retry(Context ctx,
                                    java.lang.String targetID,
                                    int remaining,
                                    java.lang.Throwable cause)

isWriteErrorsToLog

public boolean isWriteErrorsToLog()

setWriteErrorsToLog

public void setWriteErrorsToLog(boolean writeErrorsToLog)

getRetryLogic

public java.util.function.Predicate<java.lang.Throwable> getRetryLogic()

setRetryLogic

public void setRetryLogic(java.util.function.Predicate<java.lang.Throwable> retryLogic)

getMaxCallLevel

public int getMaxCallLevel()

setMaxCallLevel

public void setMaxCallLevel(int maxCallLevel)