ServiceBroker broker = new ServiceBroker();

// Create a Service
broker.createService(new Service("test") {
    public Action action = ctx -> {
        return ctx.params.get("a", 0) +
               ctx.params.get("b", 0);
    };
});

// Invoke the Action of the Service
broker.call("test.action", "a", 3, "b", 4).then(rsp -> {
    System.out.println(rsp);
});

// Solution #1
// Configuration with ServiceBrokerConfig:
ServiceBrokerConfig config = new ServiceBrokerConfig();

config.setNodeID("node1");
config.setTransporter(new RedisTransporter("redis://host"));
config.setStrategyFactory(new CpuUsageStrategyFactory());
config.setCacher(new MemoryCacher());

ServiceBroker broker = new ServiceBroker(config);

// Solution #2
// Configuration with ServiceBroker.builder:
ServiceBroker broker = ServiceBroker.builder()
                                    .nodeID("node1")
                                    .transporter(...)
                                    .strategy(...)
                                    .cacher(...)
                                    .build();

package my.services;

import org.springframework.stereotype.Controller;
import services.moleculer.service.*;

@Name("service1")
@Controller
public class TestService extends Service {

    @Name("action1")
    public Action testAction = ctx -> {
        return ctx.params.get("a").asInteger()
             + ctx.params.get("b").asInteger();
    };
    
}

import org.springframework.boot.autoconfigure.*;
import org.springframework.context.annotation.*;
import services.moleculer.config.*;
import services.moleculer.*;

@SpringBootApplication
@ComponentScan("my.services")
public class MoleculerApplication {

    // --- CREATE AND CONFIGURE SERVICE BROKER ---

    @Bean(initMethod = "start", destroyMethod = "stop")
    public ServiceBroker getServiceBroker() {
        ServiceBrokerConfig config = new ServiceBrokerConfig();
        config.setNodeID("node1");
        config.setTransporter(...);
        config.setStrategyFactory(...);
        config.setCacher(...);
        return new ServiceBroker(config);
    }

    // --- SPRING REGISTRATOR FOR MOLECULER SERVICES ---

    @Bean
    public SpringRegistrator getSpringRegistrator() {
        return new SpringRegistrator();
    }

}