ServiceBroker (moleculer-java 1.0.2 API)

java.lang.Object
- services.moleculer.ServiceBroker

```
public class ServiceBroker
extends java.lang.Object
```
The ServiceBroker is the main component of Moleculer. It handles services & events, calls actions and communicates with remote nodes. You need to create an instance of ServiceBroker for every node. Features of Moleculer:
- Fast - High-performance and non-blocking
- Polyglot - Moleculer is implemented under Node.js and Java
- Extensible - All built-in modules (caching, serializer, transporter) are pluggable
- Open source - Moleculer is 100% open source and free of charge
- Fault tolerant - With built-in load balancer & circuit breaker
Sample of usage:
```
 ServiceBroker broker = new ServiceBroker("node-1");

 broker.createService(new Service("math") {
        public Action add = ctx -> {
                return ctx.params.get("a").asInteger() + ctx.params.get("b").asInteger();
        };
 });

 broker.start();

 broker.call("math.add", "a", 5, "b", 3).then(rsp -> {
        broker.getLogger().info("Response: " + rsp.asInteger());
 });
 
```
This project is based on the idea of Moleculer Microservices Framework for Node.js (https://moleculer.services). Special thanks to the Moleculer's project owner (https://github.com/icebob) for the consultations.

Field Summary

Fields
Modifier and Type	Field and Description
`protected ServiceBrokerConfig`	`config` Configuration settings and internal components (event bus, cacher, service registry, etc.) of this node / broker.
`protected ContextFactory`	`contextFactory` Context generator / factory.
`protected Eventbus`	`eventbus` Implementation of the event bus of the current node.
`protected static org.slf4j.Logger`	`logger` SLF4J logger of this class.
`protected java.util.LinkedHashSet<Middleware>`	`middlewares` Middlewares which defined and added to the Broker before the boot process.
`protected java.lang.String`	`nodeID` Unique ID of this node (~= ServiceBroker instance).
`static java.lang.String`	`PROTOCOL_VERSION` Version of the implemented Moleculer Protocol.
`protected ServiceInvoker`	`serviceInvoker` Service invoker.
`protected ServiceRegistry`	`serviceRegistry` Implementation of the service registry of the current node.
`protected java.util.LinkedHashMap<java.lang.String,Service>`	`services` Services which defined and added to the Broker before the boot process.
`static java.lang.String`	`SOFTWARE_VERSION` Version of the Java ServiceBroker API.
`protected StrategyFactory`	`strategyFactory` Default (round-robin) service invocation factory.
`protected Transporter`	`transporter` Implementation of the Transporter.
`protected UidGenerator`	`uidGenerator` UID generator (each `Context` instance has its own identifier).

Constructor Summary

Constructors
Constructor and Description
`ServiceBroker()` Creates a new ServiceBroker without `Transporter`.
`ServiceBroker(ServiceBrokerConfig config)` Creates a new ServiceBroker by the specified `configuration`.
`ServiceBroker(java.lang.String nodeID)` Creates a new ServiceBroker without `Transporter` and with the specified `nodeID`.
`ServiceBroker(java.lang.String nodeID, Cacher cacher, Transporter transporter)` Creates a new ServiceBroker with the specified `nodeID`, `Cacher`, and `Transporter`.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`broadcast(java.lang.String name, java.lang.Object... params)` Emits an event to ALL listeners from ALL (or the specified) event group(s), who are listening this event.
`void`	`broadcast(java.lang.String name, io.datatree.Tree payload)` Emits an event to ALL listeners from ALL event groups, who are listening this event.
`void`	`broadcast(java.lang.String name, io.datatree.Tree payload, Groups groups)` Emits an event to ALL listeners from the specified event group(s), who are listening this event.
`void`	`broadcastLocal(java.lang.String name, java.lang.Object... params)` Emits a LOCAL event to ALL listeners from ALL (or the specified) event group(s), who are listening this event.
`void`	`broadcastLocal(java.lang.String name, io.datatree.Tree payload)` Emits a LOCAL event to ALL listeners from ALL event groups, who are listening this event.
`void`	`broadcastLocal(java.lang.String name, io.datatree.Tree payload, Groups groups)` Emits a LOCAL event to ALL listeners from the specified event group(s), who are listening this event.
`static ServiceBrokerBuilder`	`builder()` Creates a new `ServiceBrokerBuilder` instance.
`io.datatree.Promise`	`call(java.lang.String name, java.lang.Object... params)` Calls an action (local or remote).
`io.datatree.Promise`	`call(java.lang.String name, io.datatree.Tree params)` Calls an action (local or remote).
`io.datatree.Promise`	`call(java.lang.String name, io.datatree.Tree params, CallOptions.Options opts)` Calls an action (local or remote).
`void`	`createService(Service service)` Installs a new service instance and notifies other nodes about the actions/listeners of the new service.
`void`	`createService(java.lang.String name, Service service)` Installs a new service with the specified name (eg.
`void`	`emit(java.lang.String name, java.lang.Object... params)` Emits an event to ONE listener from ALL (or the specified) event group(s), who are listening this event.
`void`	`emit(java.lang.String name, io.datatree.Tree payload)` Emits an event to ONE listener from ALL event groups, who are listening this event.
`void`	`emit(java.lang.String name, io.datatree.Tree payload, Groups groups)` Emits an event to ONE listener from the specified event group(s), who are listening this event.
`Action`	`getAction(java.lang.String actionName)` Returns an action by name.
`Action`	`getAction(java.lang.String actionName, java.lang.String nodeID)` Returns an action by name and nodeID.
`ServiceBrokerConfig`	`getConfig()` Returns the configuration settings and internal components (event bus, cacher, service registry, etc.) of this node / broker.
`Service`	`getLocalService(java.lang.String serviceName)` Returns a local service by name (eg.
`org.slf4j.Logger`	`getLogger()` Returns the SLF4J logger of this broker instance.
`org.slf4j.Logger`	`getLogger(java.lang.Class<?> clazz)` Returns a logger named corresponding to the class passed as parameter.
`org.slf4j.Logger`	`getLogger(java.lang.String name)` Return a logger named according to the name parameter.
`java.lang.String`	`getNodeID()` Returns the unique `nodeID` of this node (~= ServiceBroker instance).
`io.datatree.Promise`	`ping(long timeoutMillis, java.lang.String nodeID)` Sends a PING message to the specified node.
`io.datatree.Promise`	`ping(java.lang.String nodeID)` Sends a PING message to the specified node.
`boolean`	`repl()` Starts a local (System in/out) developer console.
`boolean`	`repl(boolean local)` Starts a local (System in/out) or a remote (telnet-based) developer console.
`void`	`start()` Start broker.
`protected <TYPE extends MoleculerComponent> TYPE`	`start(TYPE component)` Starts the specified `MoleculerComponent`.
`void`	`stop()` Stop broker and all internal components (event bus, context factory, etc.).
`protected void`	`stop(MoleculerComponent component)` Stops the specified `MoleculerComponent`.
`void`	`use(java.util.Collection<Middleware> middlewares)` Installs a collection of middlewares.
`void`	`use(Middleware... middlewares)` Installs one or an array of middleware(s).
`io.datatree.Promise`	`waitForServices(long timeoutMillis, java.util.Collection<java.lang.String> services)` Waits for a collection of services.
`io.datatree.Promise`	`waitForServices(long timeoutMillis, java.lang.String... services)` Waits for one (or an array of) service(s).
`io.datatree.Promise`	`waitForServices(java.lang.String... services)` Waits for one or more services.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - SOFTWARE_VERSION
```
public static final java.lang.String SOFTWARE_VERSION
```
    Version of the Java ServiceBroker API.
    
    See Also:
    
    Constant Field Values
  - PROTOCOL_VERSION
```
public static final java.lang.String PROTOCOL_VERSION
```
    Version of the implemented Moleculer Protocol.
    
    See Also:
    
    Constant Field Values
  - logger
```
protected static final org.slf4j.Logger logger
```
    SLF4J logger of this class.
  - nodeID
```
protected final java.lang.String nodeID
```
    Unique ID of this node (~= ServiceBroker instance).
  - config
```
protected final ServiceBrokerConfig config
```
    Configuration settings and internal components (event bus, cacher, service registry, etc.) of this node / broker. Use the getConfig method to access this object.
  - services
```
protected final java.util.LinkedHashMap<java.lang.String,Service> services
```
    Services which defined and added to the Broker before the boot process.
  - middlewares
```
protected final java.util.LinkedHashSet<Middleware> middlewares
```
    Middlewares which defined and added to the Broker before the boot process.
  - uidGenerator
```
protected UidGenerator uidGenerator
```
    UID generator (each Context instance has its own identifier). Use getConfig().getUidGenerator() to access this instance.
    
    See Also:
    
    IncrementalUidGenerator, StandardUidGenerator
  - strategyFactory
```
protected StrategyFactory strategyFactory
```
    Default (round-robin) service invocation factory. Use getConfig().getStrategyFactory() to access this instance.
    
    See Also:
    
    RoundRobinStrategyFactory, NanoSecRandomStrategyFactory, SecureRandomStrategyFactory, XorShiftRandomStrategyFactory, CpuUsageStrategyFactory, NetworkLatencyStrategyFactory
  - contextFactory
```
protected ContextFactory contextFactory
```
    Context generator / factory. Use getConfig().getContextFactory() to access this instance.
    
    See Also:
    
    DefaultContextFactory
  - serviceInvoker
```
protected ServiceInvoker serviceInvoker
```
    Service invoker. Use getConfig().getServiceInvoker() to access this instance.
    
    See Also:
    
    DefaultServiceInvoker, CircuitBreaker
  - eventbus
```
protected Eventbus eventbus
```
    Implementation of the event bus of the current node. Use getConfig().getEventbus() to access this instance.
    
    See Also:
    
    DefaultEventbus, broadcast(String, Object...), emit(String, Object...)
  - serviceRegistry
```
protected ServiceRegistry serviceRegistry
```
    Implementation of the service registry of the current node. Use getConfig().getServiceRegistry() to access this instance.
    
    See Also:
    
    DefaultServiceRegistry, call(String, Object...)
  - transporter
```
protected Transporter transporter
```
    Implementation of the Transporter. Use getConfig().getTransporter() to access this instance. Can be null.
    
    See Also:
    
    TcpTransporter, RedisTransporter, NatsTransporter, MqttTransporter, JmsTransporter, GoogleTransporter, KafkaTransporter, AmqpTransporter
- Constructor Detail
  - ServiceBroker
```
public ServiceBroker(ServiceBrokerConfig config)
```
    Creates a new ServiceBroker by the specified configuration.
    
    Parameters:
    
    config - configuration of the Broker
  - ServiceBroker
```
public ServiceBroker()
```
    Creates a new ServiceBroker without Transporter. The nodeID is generated from the host name and process ID.
  - ServiceBroker
```
public ServiceBroker(java.lang.String nodeID)
```
    Creates a new ServiceBroker without Transporter and with the specified nodeID.
    
    Parameters:
    
    nodeID - the unique nodeID of this node
  - ServiceBroker
```
public ServiceBroker(java.lang.String nodeID,
                     Cacher cacher,
                     Transporter transporter)
```
    Creates a new ServiceBroker with the specified nodeID, Cacher, and Transporter.
    
    Parameters:
    
    nodeID - the unique nodeID of this node
    
    cacher - Cacher of this broker instance
    
    transporter - Transporter of this broker instance
- Method Detail
  - builder
```
public static ServiceBrokerBuilder builder()
```
    Creates a new ServiceBrokerBuilder instance. Sample of usage:
    
    ServiceBroker broker = ServiceBroker.builder().cacher(cacher).build();
    
    Returns:
    
    builder instance
  - getConfig
```
public ServiceBrokerConfig getConfig()
```
    Returns the configuration settings and internal components (event bus, cacher, service registry, etc.) of this node / broker.
    
    Returns:
    
    configuration container
  - getNodeID
```
public java.lang.String getNodeID()
```
    Returns the unique nodeID of this node (~= ServiceBroker instance).
    
    Returns:
    
    unique nodeID
  - start
```
public void start()
           throws java.lang.Exception
```
    Start broker. If has a Transporter, transporter.connect() will be called.
    
    Throws:
    
    fatal - error (missing classes or JARs, used port, etc.)
    
    java.lang.Exception
  - start
```
protected <TYPE extends MoleculerComponent> TYPE start(TYPE component)
                                                throws java.lang.Exception
```
    Starts the specified MoleculerComponent.
    
    Parameters:
    
    TYPE - component to start
    
    Returns:
    
    the started component
    
    Throws:
    
    java.lang.Exception - any configuration or I/O exceptions
  - stop
```
public void stop()
```
    Stop broker and all internal components (event bus, context factory, etc.). If the Broker has a Transporter, transporter.disconnect() will be called.
  - stop
```
protected void stop(MoleculerComponent component)
```
    Stops the specified MoleculerComponent.
    
    Parameters:
    
    component - component to stop
  - getLogger
```
public org.slf4j.Logger getLogger()
```
    Returns the SLF4J logger of this broker instance.
    
    Returns:
    
    logger instance
  - getLogger
```
public org.slf4j.Logger getLogger(java.lang.Class<?> clazz)
```
    Returns a logger named corresponding to the class passed as parameter.
    
    Parameters:
    
    clazz - the returned logger will be named after clazz
    
    Returns:
    
    logger instance
  - getLogger
```
public org.slf4j.Logger getLogger(java.lang.String name)
```
    Return a logger named according to the name parameter.
    
    Parameters:
    
    name - the name of the logger
    
    Returns:
    
    logger instance
  - createService
```
public void createService(Service service)
```
    Installs a new service instance and notifies other nodes about the actions/listeners of the new service.
    
    Parameters:
    
    service - the new service instance
  - createService
```
public void createService(java.lang.String name,
                          Service service)
```
    Installs a new service with the specified name (eg. "user" service) and notifies other nodes about the actions/listeners of this new service.
    
    Parameters:
    
    name - custom service name (eg. "user", "logger", "configurator", etc.)
    
    service - the new service instance
  - getLocalService
```
public Service getLocalService(java.lang.String serviceName)
```
    Returns a local service by name (eg. "user" service).
    
    Parameters:
    
    serviceName - service name (eg. "user", "logger", "configurator", etc.)
    
    Returns:
    
    local service instance
    
    Throws:
    
    NoSuchElementException - if the service name is not valid
  - use
```
public void use(java.util.Collection<Middleware> middlewares)
```
    Installs a collection of middlewares.
    
    Parameters:
    
    middlewares - collection of middlewares
  - use
```
public void use(Middleware... middlewares)
```
    Installs one or an array of middleware(s).
    
    Parameters:
    
    middlewares - array of middlewares
  - getAction
```
public Action getAction(java.lang.String actionName)
```
    Returns an action by name.
    
    Parameters:
    
    actionName - name of the action (in "service.action" syntax, eg. "math.add")
    
    Returns:
    
    local or remote action container
  - getAction
```
public Action getAction(java.lang.String actionName,
                        java.lang.String nodeID)
```
    Returns an action by name and nodeID.
    
    Parameters:
    
    actionName - name of the action (in "service.action" syntax, eg. "math.add")
    
    nodeID - node identifier where the service is located
    
    Returns:
    
    local or remote action container
  - call
```
public io.datatree.Promise call(java.lang.String name,
                                java.lang.Object... params)
```
    Calls an action (local or remote). Sample code:
    
    Promise promise = broker.call("math.add", "a", 1, "b", 2);
    
    ...or with CallOptions:
    
    broker.call("math.add", "a", 1, "b", 2, CallOptions.nodeID("node2"));
    
    Parameters:
    
    name - action name (eg. "math.add" in "service.action" syntax)
    
    params - list of parameter name-value pairs and an optional CallOptions
    
    Returns:
    
    response Promise
  - call
```
public io.datatree.Promise call(java.lang.String name,
                                io.datatree.Tree params)
```
    Calls an action (local or remote). Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    Promise promise = broker.call("math.add", params);
    
    Parameters:
    
    name - action name (eg. "math.add" in "service.action" syntax)
    
    params - Tree structure (input parameters of the method call)
    
    Returns:
    
    response Promise
  - call
```
public io.datatree.Promise call(java.lang.String name,
                                io.datatree.Tree params,
                                CallOptions.Options opts)
```
    Calls an action (local or remote). Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    Promise promise = broker.call("math.add", params, CallOptions.nodeID("node2"));
    
    Parameters:
    
    name - action name (eg. "math.add" in "service.action" syntax)
    
    params - Tree structure (input parameters of the method call)
    
    opts - calling options (target nodeID, call timeout, number of retries)
    
    Returns:
    
    response Promise
  - emit
```
public void emit(java.lang.String name,
                 java.lang.Object... params)
```
    Emits an event to ONE listener from ALL (or the specified) event group(s), who are listening this event. The service broker uses the default strategy of the broker for event redirection and node selection. Sample code:
    
    broker.emit("user.deleted", "a", 1, "b", 2);
    
    ...or send event to (one or more) listener group(s):
    
    broker.emit("user.deleted", "a", 1, "b", 2, Groups.of("logger"));
    
    Parameters:
    
    name - name of event (eg. "user.deleted")
    
    params - list of parameter name-value pairs and an optional event group container
  - emit
```
public void emit(java.lang.String name,
                 io.datatree.Tree payload,
                 Groups groups)
```
    Emits an event to ONE listener from the specified event group(s), who are listening this event. The service broker uses the default strategy of the broker for event redirection and node selection. Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    broker.emit("user.created", params, Groups.of("group1", "group2"));
    
    Parameters:
    
    name - name of event (eg. "user.modified")
    
    payload - Tree structure (payload of the event)
    
    groups - event group container
  - emit
```
public void emit(java.lang.String name,
                 io.datatree.Tree payload)
```
    Emits an event to ONE listener from ALL event groups, who are listening this event. The service broker uses the default strategy of the broker for event redirection and node selection. Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    broker.emit("user.modified", params);
    
    Parameters:
    
    name - name of event (eg. "user.created")
    
    payload - Tree structure (payload of the event)
  - broadcast
```
public void broadcast(java.lang.String name,
                      java.lang.Object... params)
```
    Emits an event to ALL listeners from ALL (or the specified) event group(s), who are listening this event. Sample code:
    
    broker.broadcast("user.deleted", "a", 1, "b", 2);
    
    ...or send event to (one or more) listener group(s):
    
    broker.broadcast("user.deleted", "a", 1, "b", 2, Groups.of("logger"));
    
    Parameters:
    
    name - name of event (eg. "user.deleted")
    
    params - list of parameter name-value pairs and an optional event group container
  - broadcast
```
public void broadcast(java.lang.String name,
                      io.datatree.Tree payload,
                      Groups groups)
```
    Emits an event to ALL listeners from the specified event group(s), who are listening this event. Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    broker.broadcast("user.created", params, Groups.of("group1", "group2"));
    
    Parameters:
    
    name - name of event (eg. "user.modified")
    
    payload - Tree structure (payload of the event)
    
    groups - event group container
  - broadcast
```
public void broadcast(java.lang.String name,
                      io.datatree.Tree payload)
```
    Emits an event to ALL listeners from ALL event groups, who are listening this event. Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    broker.broadcast("user.modified", params);
    
    Parameters:
    
    name - name of event (eg. "user.created")
    
    payload - Tree structure (payload of the event)
  - broadcastLocal
```
public void broadcastLocal(java.lang.String name,
                           java.lang.Object... params)
```
    Emits a LOCAL event to ALL listeners from ALL (or the specified) event group(s), who are listening this event. Sample code:
    
    broker.broadcastLocal("user.deleted", "a", 1, "b", 2);
    
    ...or send event to (one or more) local listener group(s):
    
    broker.broadcastLocal("user.deleted", "a", 1, "b", 2, Groups.of("logger"));
    
    Parameters:
    
    name - name of event (eg. "user.deleted")
    
    params - list of parameter name-value pairs and an optional event group container
  - broadcastLocal
```
public void broadcastLocal(java.lang.String name,
                           io.datatree.Tree payload,
                           Groups groups)
```
    Emits a LOCAL event to ALL listeners from the specified event group(s), who are listening this event. Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    broker.broadcastLocal("user.created", params, Groups.of("group1", "group2"));
    
    Parameters:
    
    name - name of event (eg. "user.modified")
    
    payload - Tree structure (payload of the event)
    
    groups - event group container
  - broadcastLocal
```
public void broadcastLocal(java.lang.String name,
                           io.datatree.Tree payload)
```
    Emits a LOCAL event to ALL listeners from ALL event groups, who are listening this event. Sample code:
    
    Tree params = new Tree();
    params.put("a", true);
    params.putList("b").add(1).add(2).add(3);
    broker.broadcastLocal("user.modified", params);
    
    Parameters:
    
    name - name of event (eg. "user.created")
    
    payload - Tree structure (payload of the event)
  - waitForServices
```
public io.datatree.Promise waitForServices(java.lang.String... services)
```
    Waits for one or more services. Sample code:
    
    broker.waitForServices("logger", "printer").then(in -> {
    broker.getLogger().info("Logger and printer started");
    }
    
    Parameters:
    
    services - service names
    
    Returns:
    
    a listenable Promise
  - waitForServices
```
public io.datatree.Promise waitForServices(long timeoutMillis,
                                           java.lang.String... services)
```
    Waits for one (or an array of) service(s). Sample code:
    
    broker.waitForServices(5000, "logger").then(in -> {
    broker.getLogger().info("Logger started successfully");
    }.catchError(error -> {
    broker.getLogger().info("Logger did not start");
    }
    
    Parameters:
    
    timeoutMillis - timeout in milliseconds
    
    services - array of service names
    
    Returns:
    
    listenable Promise
  - waitForServices
```
public io.datatree.Promise waitForServices(long timeoutMillis,
                                           java.util.Collection<java.lang.String> services)
```
    Waits for a collection of services. Sample code:
    
    Set<String> serviceNames = ...
    broker.waitForServices(5000, serviceNames).then(in -> {
    broker.getLogger().info("Ok");
    }.catchError(error -> {
    broker.getLogger().info("Failed / timeout");
    }
    
    Parameters:
    
    timeoutMillis - timeout in milliseconds
    
    services - collection of service names
    
    Returns:
    
    listenable Promise
  - ping
```
public io.datatree.Promise ping(java.lang.String nodeID)
```
    Sends a PING message to the specified node. The ping timeout is 3 seconds. Sample:
    
    broker.ping("node2").then(in -> {
    broker.getLogger().info("Ok");
    }.catchError(error -> {
    broker.getLogger().info("Ping timeouted");
    }
    
    Parameters:
    
    nodeID - node ID of the destination node
    
    Returns:
    
    listenable Promise
  - ping
```
public io.datatree.Promise ping(long timeoutMillis,
                                java.lang.String nodeID)
```
    Sends a PING message to the specified node. Sample:
    
    broker.ping(5000, "node2").then(in -> {
    broker.getLogger().info("Ok");
    }.catchError(error -> {
    broker.getLogger().info("Ping timeouted");
    }
    
    Parameters:
    
    timeoutMillis - ping timeout in milliseconds
    
    nodeID - node ID of the destination node
    
    Returns:
    
    listenable Promise
  - repl
```
public boolean repl()
```
    Starts a local (System in/out) developer console. You must install "moleculer-java-repl" dependency for use this feature.
    
    Returns:
    
    true if started
  - repl
```
public boolean repl(boolean local)
```
    Starts a local (System in/out) or a remote (telnet-based) developer console. You must install "moleculer-java-repl" dependency to use this feature.
    
    Parameters:
    
    local - true = local console, false = telnet-based console
    
    Returns:
    
    true if started

Class ServiceBroker

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

SOFTWARE_VERSION

PROTOCOL_VERSION

logger

nodeID

config

services

middlewares

uidGenerator

strategyFactory

contextFactory

serviceInvoker

eventbus

serviceRegistry

transporter

Constructor Detail

ServiceBroker

ServiceBroker

ServiceBroker

ServiceBroker

Method Detail

builder

getConfig

getNodeID

start

start

stop

stop

getLogger

getLogger

getLogger

createService

createService

getLocalService

use

use

getAction

getAction

call

call

call

emit

emit

emit

broadcast

broadcast

broadcast

broadcastLocal

broadcastLocal

broadcastLocal

waitForServices

waitForServices

waitForServices

ping

ping

repl

repl