services.moleculer.eventbus

Class Eventbus

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.eventbus.Eventbus

Direct Known Subclasses:

DefaultEventbus

public abstract class Eventbus
extends MoleculerComponent

Base superclass of all Event Bus implementations.

See Also:

DefaultEventBus

Field Summary

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
Eventbus()

Method Summary

Modifier and Type	Method and Description
abstract void	addListeners(java.lang.String name, Service service)
abstract void	addListeners(io.datatree.Tree config)
abstract void	broadcast(java.lang.String name, io.datatree.Tree payload, Groups groups, boolean local)
abstract void	emit(java.lang.String name, io.datatree.Tree payload, Groups groups, boolean local)
abstract io.datatree.Tree	generateListenerDescriptor(java.lang.String service)
abstract void	receiveEvent(io.datatree.Tree message)
abstract void	removeListeners(java.lang.String nodeID)

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName, started, stopped

Methods inherited from class java.lang.Object

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

Constructor Detail

Eventbus

public Eventbus()

Method Detail

receiveEvent

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

addListeners

public abstract void addListeners(java.lang.String name,
                                  Service service)

addListeners

public abstract void addListeners(io.datatree.Tree config)

removeListeners

public abstract void removeListeners(java.lang.String nodeID)

emit

public abstract void emit(java.lang.String name,
                          io.datatree.Tree payload,
                          Groups groups,
                          boolean local)

broadcast

public abstract void broadcast(java.lang.String name,
                               io.datatree.Tree payload,
                               Groups groups,
                               boolean local)

generateListenerDescriptor

public abstract io.datatree.Tree generateListenerDescriptor(java.lang.String service)