services.moleculer.service

Class DefaultServiceInvoker

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.ServiceInvoker

services.moleculer.service.DefaultServiceInvoker

Direct Known Subclasses:

CircuitBreaker

public class DefaultServiceInvoker
extends ServiceInvoker

Default service invoker with retry logic.

Field Summary

Fields

Modifier and Type	Field and Description
protected ContextFactory	contextFactory
protected java.util.function.Predicate<java.lang.Throwable>	retryLogic
protected ServiceRegistry	serviceRegistry
protected boolean	writeErrorsToLog Write exceptions into the log file

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
DefaultServiceInvoker()

Method Summary

Modifier and Type	Method and Description
io.datatree.Promise	call(java.lang.String name, io.datatree.Tree params, CallOptions.Options opts, PacketStream stream, Context parent)
protected io.datatree.Promise	call(java.lang.String name, io.datatree.Tree params, CallOptions.Options opts, PacketStream stream, Context parent, java.lang.String targetID, int remaining)
java.util.function.Predicate<java.lang.Throwable>	getRetryLogic()
boolean	isWriteErrorsToLog()
protected io.datatree.Promise	retry(java.lang.Throwable cause, java.lang.String name, io.datatree.Tree params, CallOptions.Options opts, PacketStream stream, Context parent, java.lang.String targetID, int remaining)
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

serviceRegistry

protected ServiceRegistry serviceRegistry

contextFactory

protected ContextFactory contextFactory

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

Overrides:

started in class MoleculerComponent

Throws:

java.lang.Exception

call

public io.datatree.Promise call(java.lang.String name,
                                io.datatree.Tree params,
                                CallOptions.Options opts,
                                PacketStream stream,
                                Context parent)

Specified by:

call in class ServiceInvoker

call

protected io.datatree.Promise call(java.lang.String name,
                                   io.datatree.Tree params,
                                   CallOptions.Options opts,
                                   PacketStream stream,
                                   Context parent,
                                   java.lang.String targetID,
                                   int remaining)

retry

protected io.datatree.Promise retry(java.lang.Throwable cause,
                                    java.lang.String name,
                                    io.datatree.Tree params,
                                    CallOptions.Options opts,
                                    PacketStream stream,
                                    Context parent,
                                    java.lang.String targetID,
                                    int remaining)

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)