services.moleculer.eventbus

Class DefaultEventbus

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.eventbus.Eventbus

services.moleculer.eventbus.DefaultEventbus

public class DefaultEventbus
extends Eventbus

Default EventBus implementation.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	asyncLocalInvocation Invoke all local listeners via Thread pool (true) or directly (false)
protected io.datatree.dom.Cache<java.lang.String,ListenerEndpoint[]>	broadcasterCache
protected boolean	checkVersion Check protocol version
protected io.datatree.dom.Cache<java.lang.String,Strategy<ListenerEndpoint>[]>	emitterCache
protected java.util.concurrent.ExecutorService	executor
protected java.util.HashMap<java.lang.String,java.util.HashMap<java.lang.String,Strategy<ListenerEndpoint>>>	listeners
protected io.datatree.dom.Cache<java.lang.String,ListenerEndpoint[]>	localBroadcasterCache
protected java.lang.String	nodeID Local Node ID
protected java.util.concurrent.locks.Lock	readLock Reader lock of the Event Bus
protected StrategyFactory	strategy
protected Transporter	transporter
protected java.util.concurrent.locks.Lock	writeLock Writer lock of the Event Bus

Fields inherited from class services.moleculer.service.MoleculerComponent

broker, logger, name

Constructor Summary

Constructors

Constructor and Description
DefaultEventbus()
DefaultEventbus(boolean asyncLocalInvocation)

Method Summary

Modifier and Type	Method and Description
void	addListeners(java.lang.String serviceName, Service service)
void	addListeners(io.datatree.Tree config)
void	broadcast(java.lang.String name, io.datatree.Tree payload, Groups groups, boolean local)
void	emit(java.lang.String name, io.datatree.Tree payload, Groups groups, boolean local)
io.datatree.Tree	generateListenerDescriptor(java.lang.String service)
protected java.lang.String	getCacheKey(java.lang.String name, Groups groups)
boolean	isAsyncLocalInvocation()
boolean	isCheckVersion()
void	receiveEvent(io.datatree.Tree message)
void	removeListeners(java.lang.String nodeID)
void	setAsyncLocalInvocation(boolean asyncLocalInvocation)
void	setCheckVersion(boolean checkVersion)
void	started(ServiceBroker broker) Initializes default EventBus instance.
void	stopped()

Methods inherited from class services.moleculer.service.MoleculerComponent

getBroker, getLogger, getName

Methods inherited from class java.lang.Object

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

Field Detail

listeners

protected final java.util.HashMap<java.lang.String,java.util.HashMap<java.lang.String,Strategy<ListenerEndpoint>>> listeners

emitterCache

protected final io.datatree.dom.Cache<java.lang.String,Strategy<ListenerEndpoint>[]> emitterCache

broadcasterCache

protected final io.datatree.dom.Cache<java.lang.String,ListenerEndpoint[]> broadcasterCache

localBroadcasterCache

protected final io.datatree.dom.Cache<java.lang.String,ListenerEndpoint[]> localBroadcasterCache

asyncLocalInvocation

protected boolean asyncLocalInvocation

Invoke all local listeners via Thread pool (true) or directly (false)

checkVersion

protected boolean checkVersion

Check protocol version

nodeID

protected java.lang.String nodeID

Local Node ID

readLock

protected final java.util.concurrent.locks.Lock readLock

Reader lock of the Event Bus

writeLock

protected final java.util.concurrent.locks.Lock writeLock

Writer lock of the Event Bus

strategy

protected StrategyFactory strategy

transporter

protected Transporter transporter

executor

protected java.util.concurrent.ExecutorService executor

Constructor Detail

DefaultEventbus

public DefaultEventbus()

DefaultEventbus

public DefaultEventbus(boolean asyncLocalInvocation)

Method Detail

started

public void started(ServiceBroker broker)
             throws java.lang.Exception

Initializes default EventBus instance.

Overrides:

started in class MoleculerComponent

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.Exception

stopped

public void stopped()

Overrides:

stopped in class MoleculerComponent

receiveEvent

public void receiveEvent(io.datatree.Tree message)

Specified by:

receiveEvent in class Eventbus

addListeners

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

Specified by:

addListeners in class Eventbus

addListeners

public void addListeners(io.datatree.Tree config)

Specified by:

addListeners in class Eventbus

removeListeners

public void removeListeners(java.lang.String nodeID)

Specified by:

removeListeners in class Eventbus

emit

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

Specified by:

emit in class Eventbus

broadcast

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

Specified by:

broadcast in class Eventbus

getCacheKey

protected java.lang.String getCacheKey(java.lang.String name,
                                       Groups groups)

generateListenerDescriptor

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

Specified by:

generateListenerDescriptor in class Eventbus

isCheckVersion

public boolean isCheckVersion()

setCheckVersion

public void setCheckVersion(boolean checkVersion)

isAsyncLocalInvocation

public boolean isAsyncLocalInvocation()

setAsyncLocalInvocation

public void setAsyncLocalInvocation(boolean asyncLocalInvocation)