Class ServiceBrokerConfig

java.lang.Object
services.moleculer.config.ServiceBrokerConfig
public class ServiceBrokerConfig extends Object

  • Field Details

    • executor

      protected ExecutorService executor

    • scheduler

      protected ScheduledExecutorService scheduler

    • shutDownThreadPools

      protected boolean shutDownThreadPools

    • namespace

      protected String namespace
      Namespace of Broker.

    • nodeID

      protected String nodeID
      Unique NodeID of Broker.

    • DEFAULT_PROTOCOL_VERSION

      public static final String DEFAULT_PROTOCOL_VERSION
      Default Moleculer wire-protocol version stamped onto outgoing packets. Moleculer JS 0.15 speaks "5" (and silently drops packets with a different "ver"); 0.14 spoke "4". The two are wire-compatible for the JSON serializer, so "5" is the default to interoperate with current Moleculer JS out of the box. Set setProtocolVersion(String) to "4" when talking to legacy 0.14 nodes.
      See Also:

    • protocolVersion

      protected String protocolVersion
      Moleculer wire-protocol version ("ver" field). Seeded from the "moleculer.protocol.version" System Property, falling back to DEFAULT_PROTOCOL_VERSION; override per broker via setProtocolVersion(String).

    • internalServices

      protected boolean internalServices
      Install internal ($node) services?

    • jsonReaders

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

    • jsonWriters

      protected 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 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 Details

    • ServiceBrokerConfig

      public ServiceBrokerConfig()

    • ServiceBrokerConfig

      public ServiceBrokerConfig(String nodeID, Cacher cacher, Transporter transporter)

  • Method Details

    • getExecutor

      public ExecutorService getExecutor()

    • setExecutor

      public void setExecutor(ExecutorService executor)

    • getScheduler

      public ScheduledExecutorService getScheduler()

    • setScheduler

      public void setScheduler(ScheduledExecutorService scheduler)

    • isShutDownThreadPools

      public boolean isShutDownThreadPools()

    • setShutDownThreadPools

      public void setShutDownThreadPools(boolean shutDownThreadPools)

    • getNamespace

      public String getNamespace()

    • setNamespace

      public void setNamespace(String namespace)

    • getNodeID

      public String getNodeID()

    • setNodeID

      public void setNodeID(String nodeID)

    • getProtocolVersion

      public String getProtocolVersion()

    • setProtocolVersion

      public void setProtocolVersion(String protocolVersion)

    • isInternalServices

      public boolean isInternalServices()

    • setInternalServices

      public void setInternalServices(boolean internalServices)

    • getJsonReaders

      public String getJsonReaders()

    • setJsonReaders

      public void setJsonReaders(String jsonReader)

    • getJsonWriters

      public String getJsonWriters()

    • setJsonWriters

      public void setJsonWriters(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)