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 int	maxCallLevel Max call level (for nested events)
protected java.lang.String	nodeID Local Node ID
protected java.util.concurrent.locks.Lock	registryReadLock Reader lock of the Event Bus
protected java.util.concurrent.locks.Lock	registryWriteLock Writer lock of the Event Bus
protected java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock	requestStreamReadLock
protected java.util.HashMap<java.lang.String,IncomingStream>	requestStreams
protected java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock	requestStreamWriteLock
protected java.util.concurrent.ScheduledExecutorService	scheduler
protected ServiceInvoker	serviceInvoker
protected StrategyFactory	strategy
protected long	streamTimeout Stream inactivity/read timeout in MILLISECONDS (0 = no timeout).
protected java.util.concurrent.ScheduledFuture<?>	streamTimeoutTimer Cancelable timer for request streams
protected Transporter	transporter
protected UidGenerator	uidGenerator
protected boolean	writeErrorsToLog Write exceptions into the log file

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(java.lang.String nodeID, io.datatree.Tree config)
void	broadcast(Context ctx, Groups groups, boolean local)
protected void	checkTimeouts()
void	emit(Context ctx, Groups groups, boolean local)
io.datatree.Tree	generateListenerDescriptor(java.lang.String service)
protected java.lang.String	getCacheKey(java.lang.String name, Groups groups)
int	getMaxCallLevel()
long	getStreamTimeout()
boolean	isAsyncLocalInvocation()
boolean	isCheckVersion()
boolean	isWriteErrorsToLog()
void	receiveEvent(io.datatree.Tree message)
void	removeListeners(java.lang.String nodeID)
void	setAsyncLocalInvocation(boolean asyncLocalInvocation)
void	setCheckVersion(boolean checkVersion)
void	setMaxCallLevel(int maxCallLevel)
void	setStreamTimeout(long streamTimeout)
void	setWriteErrorsToLog(boolean writeErrorsToLog)
void	started(ServiceBroker broker) Initializes default EventBus instance.
void	stopped()
protected void	stopStreaming(Context ctx)

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

writeErrorsToLog

protected boolean writeErrorsToLog

Write exceptions into the log file

streamTimeout

protected long streamTimeout

Stream inactivity/read timeout in MILLISECONDS (0 = no timeout). It may be useful if you want to remove the wrong packages from the memory.

maxCallLevel

protected int maxCallLevel

Max call level (for nested events)

registryReadLock

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

Reader lock of the Event Bus

registryWriteLock

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

Writer lock of the Event Bus

streamTimeoutTimer

protected java.util.concurrent.ScheduledFuture<?> streamTimeoutTimer

Cancelable timer for request streams

strategy

protected StrategyFactory strategy

transporter

protected Transporter transporter

executor

protected java.util.concurrent.ExecutorService executor

serviceInvoker

protected ServiceInvoker serviceInvoker

scheduler

protected java.util.concurrent.ScheduledExecutorService scheduler

uidGenerator

protected UidGenerator uidGenerator

requestStreams

protected final java.util.HashMap<java.lang.String,IncomingStream> requestStreams

requestStreamReadLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock requestStreamReadLock

requestStreamWriteLock

protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock requestStreamWriteLock

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

checkTimeouts

protected void checkTimeouts()

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(java.lang.String nodeID,
                         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(Context ctx,
                 Groups groups,
                 boolean local)

Specified by:

emit in class Eventbus

stopStreaming

protected void stopStreaming(Context ctx)

broadcast

public void broadcast(Context ctx,
                      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)

isWriteErrorsToLog

public boolean isWriteErrorsToLog()

setWriteErrorsToLog

public void setWriteErrorsToLog(boolean writeErrorsToLog)

getStreamTimeout

public long getStreamTimeout()

setStreamTimeout

public void setStreamTimeout(long streamTimeout)

getMaxCallLevel

public int getMaxCallLevel()

setMaxCallLevel

public void setMaxCallLevel(int maxCallLevel)