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	Description
protected Eventbus	eventbus
protected int	maxCallLevel	Max call level (for nested calls)
protected Metrics	metrics
protected Predicate<Throwable>	retryLogic
protected ServiceRegistry	serviceRegistry
protected UidGenerator	uidGenerator
protected boolean	writeErrorsToLog	Write exceptions into the log file

Fields inherited from class MoleculerComponent

broker, logger, name

Fields inherited from interface 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	Description
DefaultServiceInvoker()

Method Summary

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

Methods inherited from class MoleculerComponent

getBroker, getLogger, getName, stopped

Methods inherited from class Object

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

Field Details

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 Predicate<Throwable> retryLogic

Constructor Details

DefaultServiceInvoker

public DefaultServiceInvoker()

Method Details

started

public void started(ServiceBroker broker)
             throws Exception

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class MoleculerComponent

Throws:

Exception

call

public io.datatree.Promise call(Context ctx)

Specified by:

call in class ServiceInvoker

call

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

retry

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

isWriteErrorsToLog

public boolean isWriteErrorsToLog()

setWriteErrorsToLog

public void setWriteErrorsToLog(boolean writeErrorsToLog)

getRetryLogic

public Predicate<Throwable> getRetryLogic()

setRetryLogic

public void setRetryLogic(Predicate<Throwable> retryLogic)

getMaxCallLevel

public int getMaxCallLevel()

setMaxCallLevel

public void setMaxCallLevel(int maxCallLevel)