Class ServiceRegistry

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.service.ServiceRegistry

All Implemented Interfaces:

MoleculerLifecycle

Direct Known Subclasses:

DefaultServiceRegistry

public abstract class ServiceRegistry
extends MoleculerComponent

Base superclass of all Service Registry implementations.

See Also:

• DefaultServiceRegistry

Field Summary

Fields inherited from class MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor	Description
ServiceRegistry()

Method Summary

Modifier and Type	Method	Description
abstract void	addActions(String nodeID, io.datatree.Tree config)
abstract io.datatree.Promise	addActions(String name, Service service)
abstract Action	getAction(String name, String nodeID)
abstract io.datatree.Tree	getDescriptor()
abstract Service	getService(String name)
abstract long	getTimestamp()
abstract io.datatree.Promise	ping(long timeoutMillis, String nodeID)
abstract void	receivePong(io.datatree.Tree message)
abstract void	receiveRequest(io.datatree.Tree message)
abstract void	receiveResponse(io.datatree.Tree message)
abstract void	removeActions(String nodeID)
abstract void	use(Collection<Middleware> middlewares)
abstract io.datatree.Promise	waitForServices(long timeoutMillis, Collection<String> services)

Methods inherited from class MoleculerComponent

getBroker, getLogger, getName, started, stopped

Methods inherited from class Object

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

Constructor Details

ServiceRegistry

public ServiceRegistry()

Method Details

receiveRequest

public abstract void receiveRequest(io.datatree.Tree message)

receivePong

public abstract void receivePong(io.datatree.Tree message)

receiveResponse

public abstract void receiveResponse(io.datatree.Tree message)

use

public abstract void use(Collection<Middleware> middlewares)

addActions

public abstract io.datatree.Promise addActions(String name,
 Service service)

addActions

public abstract void addActions(String nodeID,
 io.datatree.Tree config)

removeActions

public abstract void removeActions(String nodeID)

getService

public abstract Service getService(String name)

getAction

public abstract Action getAction(String name,
 String nodeID)

waitForServices

public abstract io.datatree.Promise waitForServices(long timeoutMillis,
 Collection<String> services)

ping

public abstract io.datatree.Promise ping(long timeoutMillis,
 String nodeID)

getDescriptor

public abstract io.datatree.Tree getDescriptor()

getTimestamp

public abstract long getTimestamp()