public abstract class Eventbus extends MoleculerComponent
DefaultEventBusbroker, logger, name| Constructor and Description |
|---|
Eventbus() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
addListeners(java.lang.String name,
Service service) |
abstract void |
addListeners(java.lang.String nodeID,
io.datatree.Tree config) |
abstract void |
broadcast(Context ctx,
Groups groups,
boolean local) |
abstract void |
emit(Context ctx,
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) |
public abstract void receiveEvent(io.datatree.Tree message)
public abstract void addListeners(java.lang.String name,
Service service)
public abstract void addListeners(java.lang.String nodeID,
io.datatree.Tree config)
public abstract void removeListeners(java.lang.String nodeID)
public abstract io.datatree.Tree generateListenerDescriptor(java.lang.String service)