services.moleculer.eventbus

Class EventEmitter

java.lang.Object

services.moleculer.eventbus.EventEmitter

Direct Known Subclasses:

Context, ServiceBroker

public abstract class EventEmitter
extends java.lang.Object

Base superclass of all objects that can send events (eg. ServiceBroker or Context).

Field Summary

Fields

Modifier and Type	Field and Description
protected Eventbus	eventbus Eventbus of the parent ServiceBroker.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	EventEmitter(Eventbus eventbus)

Method Summary

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.
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.

Methods inherited from class java.lang.Object

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

Field Detail

eventbus

protected final Eventbus eventbus

Eventbus of the parent ServiceBroker.

Constructor Detail

EventEmitter

protected EventEmitter(Eventbus eventbus)

Method Detail

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:

ctx.emit("user.deleted", "a", 1, "b", 2);

...or send event to (one or more) listener group(s):

ctx.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);
ctx.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);
ctx.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:

ctx.broadcast("user.deleted", "a", 1, "b", 2);

...or send event to (one or more) listener group(s):

ctx.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);
ctx.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);
ctx.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:

ctx.broadcastLocal("user.deleted", "a", 1, "b", 2);

...or send event to (one or more) local listener group(s):

ctx.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);
ctx.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);
ctx.broadcastLocal("user.modified", params);

Parameters:

name - name of event (eg. "user.created")

payload - Tree structure (payload of the event)