services.moleculer.config

Class ServiceBrokerConfig

java.lang.Object

services.moleculer.config.ServiceBrokerConfig

public class ServiceBrokerConfig
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Cacher	cacher
protected Eventbus	eventbus
protected java.util.concurrent.ExecutorService	executor
protected java.util.concurrent.atomic.AtomicLong	instanceCounter Service Broker instance counter (0...N)
protected boolean	internalServices Install internal ($node) services?
protected java.lang.String	jsonReaders Name (or comma-separated list) of the JSON deserializer API ("jackson", "boon", "builtin", "gson", "fastjson", "genson", etc., null = autodetect / fastest)
protected java.lang.String	jsonWriters Name (or comma-separated list) of the JSON serializer API ("jackson", "boon", "builtin", "gson", "fast", "genson", "flex", "nano", etc., null = autodetect / fastest)
protected Metrics	metrics
protected boolean	metricsEnabled
protected Monitor	monitor
protected java.lang.String	namespace Namespace of Broker.
protected java.lang.String	nodeID Unique NodeID of Broker.
protected java.util.concurrent.ScheduledExecutorService	scheduler
protected ServiceInvoker	serviceInvoker
protected ServiceRegistry	serviceRegistry
protected boolean	shutDownThreadPools
protected StrategyFactory	strategyFactory
protected Transporter	transporter
protected UidGenerator	uidGenerator

Constructor Summary

Constructors

Constructor and Description
ServiceBrokerConfig()
ServiceBrokerConfig(java.lang.String nodeID, Cacher cacher, Transporter transporter)

Method Summary

Modifier and Type	Method and Description
Cacher	getCacher()
Eventbus	getEventbus()
java.util.concurrent.ExecutorService	getExecutor()
java.lang.String	getJsonReaders()
java.lang.String	getJsonWriters()
Metrics	getMetrics()
Monitor	getMonitor()
java.lang.String	getNamespace()
java.lang.String	getNodeID()
java.util.concurrent.ScheduledExecutorService	getScheduler()
ServiceInvoker	getServiceInvoker()
ServiceRegistry	getServiceRegistry()
StrategyFactory	getStrategyFactory()
Transporter	getTransporter()
UidGenerator	getUidGenerator()
boolean	isInternalServices()
boolean	isMetricsEnabled()
boolean	isShutDownThreadPools()
void	setCacher(Cacher cacher)
void	setEventbus(Eventbus eventbus)
void	setExecutor(java.util.concurrent.ExecutorService executor)
void	setInternalServices(boolean internalServices)
void	setJsonReaders(java.lang.String jsonReader)
void	setJsonWriters(java.lang.String jsonWriter)
void	setMetrics(Metrics metrics)
void	setMetricsEnabled(boolean metricsEnabled)
void	setMonitor(Monitor monitor)
void	setNamespace(java.lang.String namespace)
void	setNodeID(java.lang.String nodeID)
void	setScheduler(java.util.concurrent.ScheduledExecutorService scheduler)
void	setServiceInvoker(ServiceInvoker serviceInvoker)
void	setServiceRegistry(ServiceRegistry serviceRegistry)
void	setShutDownThreadPools(boolean shutDownThreadPools)
void	setStrategyFactory(StrategyFactory strategyFactory)
void	setTransporter(Transporter transporter)
void	setUidGenerator(UidGenerator uidGenerator)

Methods inherited from class java.lang.Object

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

Field Detail

executor

protected java.util.concurrent.ExecutorService executor

scheduler

protected java.util.concurrent.ScheduledExecutorService scheduler

shutDownThreadPools

protected boolean shutDownThreadPools

namespace

protected java.lang.String namespace

Namespace of Broker.

nodeID

protected java.lang.String nodeID

Unique NodeID of Broker.

internalServices

protected boolean internalServices

Install internal ($node) services?

jsonReaders

protected java.lang.String jsonReaders

Name (or comma-separated list) of the JSON deserializer API ("jackson", "boon", "builtin", "gson", "fastjson", "genson", etc., null = autodetect / fastest)

jsonWriters

protected java.lang.String jsonWriters

Name (or comma-separated list) of the JSON serializer API ("jackson", "boon", "builtin", "gson", "fast", "genson", "flex", "nano", etc., null = autodetect / fastest)

instanceCounter

protected java.util.concurrent.atomic.AtomicLong instanceCounter

Service Broker instance counter (0...N)

uidGenerator

protected UidGenerator uidGenerator

strategyFactory

protected StrategyFactory strategyFactory

eventbus

protected Eventbus eventbus

serviceRegistry

protected ServiceRegistry serviceRegistry

serviceInvoker

protected ServiceInvoker serviceInvoker

metrics

protected Metrics metrics

cacher

protected Cacher cacher

transporter

protected Transporter transporter

monitor

protected Monitor monitor

metricsEnabled

protected boolean metricsEnabled

Constructor Detail

ServiceBrokerConfig

public ServiceBrokerConfig()

ServiceBrokerConfig

public ServiceBrokerConfig(java.lang.String nodeID,
                           Cacher cacher,
                           Transporter transporter)

Method Detail

getExecutor

public java.util.concurrent.ExecutorService getExecutor()

setExecutor

public void setExecutor(java.util.concurrent.ExecutorService executor)

getScheduler

public java.util.concurrent.ScheduledExecutorService getScheduler()

setScheduler

public void setScheduler(java.util.concurrent.ScheduledExecutorService scheduler)

isShutDownThreadPools

public boolean isShutDownThreadPools()

setShutDownThreadPools

public void setShutDownThreadPools(boolean shutDownThreadPools)

getNamespace

public java.lang.String getNamespace()

setNamespace

public void setNamespace(java.lang.String namespace)

getNodeID

public java.lang.String getNodeID()

setNodeID

public void setNodeID(java.lang.String nodeID)

isInternalServices

public boolean isInternalServices()

setInternalServices

public void setInternalServices(boolean internalServices)

getJsonReaders

public java.lang.String getJsonReaders()

setJsonReaders

public void setJsonReaders(java.lang.String jsonReader)

getJsonWriters

public java.lang.String getJsonWriters()

setJsonWriters

public void setJsonWriters(java.lang.String jsonWriter)

getServiceRegistry

public ServiceRegistry getServiceRegistry()

setServiceRegistry

public void setServiceRegistry(ServiceRegistry serviceRegistry)

getStrategyFactory

public StrategyFactory getStrategyFactory()

setStrategyFactory

public void setStrategyFactory(StrategyFactory strategyFactory)

getUidGenerator

public UidGenerator getUidGenerator()

setUidGenerator

public void setUidGenerator(UidGenerator uidGenerator)

getEventbus

public Eventbus getEventbus()

setEventbus

public void setEventbus(Eventbus eventbus)

getCacher

public Cacher getCacher()

setCacher

public void setCacher(Cacher cacher)

getMonitor

public Monitor getMonitor()

setMonitor

public void setMonitor(Monitor monitor)

getTransporter

public Transporter getTransporter()

setTransporter

public void setTransporter(Transporter transporter)

getServiceInvoker

public ServiceInvoker getServiceInvoker()

setServiceInvoker

public void setServiceInvoker(ServiceInvoker serviceInvoker)

getMetrics

public Metrics getMetrics()

setMetrics

public void setMetrics(Metrics metrics)

isMetricsEnabled

public boolean isMetricsEnabled()

setMetricsEnabled

public void setMetricsEnabled(boolean metricsEnabled)