Mastering Microservices with Java - Third Edition

The Conductor worker

The Conductor worker is a special task that runs on a domain microservice and not the Conductor server. You need to implement the Worker interface to write the Conductor worker. There are two methods that need to be implemented; the rest use the default implementation; therefore, if required, you can override them too.

You can see that execute() is the function that implements the behavior of a task. The following is the code that explains how you can make use of input and output parameters to implement the required functionality. It's important to set the status to let Conductor decide the flow:

public class ConductorWorker implements Worker {    private static final Logger LOG =  LoggerFactory.getLogger(ConductorWorker.class); ...