Class ServiceBrokerBuilder

java.lang.Object

services.moleculer.config.ServiceBrokerBuilder

public class ServiceBrokerBuilder
extends Object

Builder-style ServiceBroker factory. Sample of usage:

ServiceBroker broker = ServiceBroker.builder().cacher(new RedisCacher()).transporter(new RedisTransporter()).build();

Field Summary

Fields

Modifier and Type	Field	Description
protected ServiceBrokerConfig	config

Constructor Summary

Constructors

Constructor	Description
ServiceBrokerBuilder()

Method Summary

Modifier and Type	Method	Description
ServiceBroker	build()
ServiceBrokerBuilder	cacher(Cacher cacher)
ServiceBrokerBuilder	eventbus(Eventbus eventBus)
ServiceBrokerBuilder	executor(ExecutorService executor)
ServiceBrokerBuilder	internalServices(boolean internalServices)
ServiceBrokerBuilder	invoker(ServiceInvoker invoker)
ServiceBrokerBuilder	metrics(Metrics metrics)
ServiceBrokerBuilder	metricsEnabled(boolean metricsEnabled)
ServiceBrokerBuilder	monitor(Monitor monitor)
ServiceBrokerBuilder	namespace(String namespace)
ServiceBrokerBuilder	nodeID(String nodeID)
ServiceBrokerBuilder	protocolVersion(String protocolVersion)
ServiceBrokerBuilder	readers(String jsonReader)
ServiceBrokerBuilder	registry(ServiceRegistry serviceRegistry)
ServiceBrokerBuilder	scheduler(ScheduledExecutorService scheduler)
ServiceBrokerBuilder	strategy(StrategyFactory strategyFactory)
ServiceBrokerBuilder	transporter(Transporter transporter)
ServiceBrokerBuilder	uid(UidGenerator uidGenerator)
ServiceBrokerBuilder	writers(String jsonWriter)

Methods inherited from class Object

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

Field Details

config

protected ServiceBrokerConfig config

Constructor Details

ServiceBrokerBuilder

public ServiceBrokerBuilder()

Method Details

build

public ServiceBroker build()

namespace

public ServiceBrokerBuilder namespace(String namespace)

nodeID

public ServiceBrokerBuilder nodeID(String nodeID)

protocolVersion

public ServiceBrokerBuilder protocolVersion(String protocolVersion)

internalServices

public ServiceBrokerBuilder internalServices(boolean internalServices)

scheduler

public ServiceBrokerBuilder scheduler(ScheduledExecutorService scheduler)

executor

public ServiceBrokerBuilder executor(ExecutorService executor)

registry

public ServiceBrokerBuilder registry(ServiceRegistry serviceRegistry)

eventbus

public ServiceBrokerBuilder eventbus(Eventbus eventBus)

uid

public ServiceBrokerBuilder uid(UidGenerator uidGenerator)

strategy

public ServiceBrokerBuilder strategy(StrategyFactory strategyFactory)

transporter

public ServiceBrokerBuilder transporter(Transporter transporter)

cacher

public ServiceBrokerBuilder cacher(Cacher cacher)

metrics

public ServiceBrokerBuilder metrics(Metrics metrics)

metricsEnabled

public ServiceBrokerBuilder metricsEnabled(boolean metricsEnabled)

monitor

public ServiceBrokerBuilder monitor(Monitor monitor)

invoker

public ServiceBrokerBuilder invoker(ServiceInvoker invoker)

readers

public ServiceBrokerBuilder readers(String jsonReader)

writers

public ServiceBrokerBuilder writers(String jsonWriter)