services.moleculer.eventbus

Class DefaultEventbus

java.lang.Object

services.moleculer.service.MoleculerComponent

services.moleculer.eventbus.Eventbus

services.moleculer.eventbus.DefaultEventbus

All Implemented Interfaces:

MetricConstants, MoleculerLifecycle

public class DefaultEventbus
extends Eventbus
implements MetricConstants

Default EventBus implementation.

Field Summary

Fields

Modifier and Type	Field and Description
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.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 Metrics	metrics
protected java.lang.String	nodeID Local Node ID
protected java.lang.String	protocolVersion ServiceBroker's protocol version
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

Fields inherited from interface services.moleculer.metrics.MetricConstants

MOLECULER_CACHER_CLEAN_TIME, MOLECULER_CACHER_CLEAN_TIME_DESC, MOLECULER_CACHER_CLEAN_TOTAL, MOLECULER_CACHER_CLEAN_TOTAL_DESC, MOLECULER_CACHER_DEL_TIME, MOLECULER_CACHER_DEL_TIME_DESC, MOLECULER_CACHER_DEL_TOTAL, MOLECULER_CACHER_DEL_TOTAL_DESC, MOLECULER_CACHER_EXPIRED_TOTAL, MOLECULER_CACHER_EXPIRED_TOTAL_DESC, MOLECULER_CACHER_FOUND_TOTAL, MOLECULER_CACHER_FOUND_TOTAL_DESC, MOLECULER_CACHER_GET_TIME, MOLECULER_CACHER_GET_TIME_DESC, MOLECULER_CACHER_GET_TOTAL, MOLECULER_CACHER_GET_TOTAL_DESC, MOLECULER_CACHER_SET_TIME, MOLECULER_CACHER_SET_TIME_DESC, MOLECULER_CACHER_SET_TOTAL, MOLECULER_CACHER_SET_TOTAL_DESC, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_HALF_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE, MOLECULER_CIRCUIT_BREAKER_OPENED_ACTIVE_DESC, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL, MOLECULER_CIRCUIT_BREAKER_OPENED_TOTAL_DESC, MOLECULER_EVENT_BROADCAST_TOTAL, MOLECULER_EVENT_BROADCAST_TOTAL_DESC, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL, MOLECULER_EVENT_BROADCASTLOCAL_TOTAL_DESC, MOLECULER_EVENT_EMIT_TOTAL, MOLECULER_EVENT_EMIT_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_ACTIVE, MOLECULER_EVENT_RECEIVED_ACTIVE_DESC, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL, MOLECULER_EVENT_RECEIVED_ERROR_TOTAL_DESC, MOLECULER_EVENT_RECEIVED_TIME, MOLECULER_EVENT_RECEIVED_TIME_DESC, MOLECULER_EVENT_RECEIVED_TOTAL, MOLECULER_EVENT_RECEIVED_TOTAL_DESC, MOLECULER_EXECUTOR, MOLECULER_REQUEST_ACTIVE, MOLECULER_REQUEST_ACTIVE_DESC, MOLECULER_REQUEST_ERROR_TOTAL, MOLECULER_REQUEST_ERROR_TOTAL_DESC, MOLECULER_REQUEST_LEVELS, MOLECULER_REQUEST_LEVELS_DESC, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL, MOLECULER_REQUEST_RETRY_ATTEMPTS_TOTAL_DESC, MOLECULER_REQUEST_TIME, MOLECULER_REQUEST_TIME_DESC, MOLECULER_REQUEST_TIMEOUT_TOTAL, MOLECULER_REQUEST_TIMEOUT_TOTAL_DESC, MOLECULER_REQUEST_TOTAL, MOLECULER_REQUEST_TOTAL_DESC, MOLECULER_SCHEDULER, MOLECULER_TRANSIT_CONNECTED, MOLECULER_TRANSIT_CONNECTED_DESC, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL, MOLECULER_TRANSIT_ORPHAN_RESPONSE_TOTAL_DESC, MOLECULER_TRANSIT_REQUESTS_ACTIVE, MOLECULER_TRANSIT_REQUESTS_ACTIVE_DESC, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE, MOLECULER_TRANSIT_STREAMS_RECEIVE_ACTIVE_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL, MOLECULER_TRANSPORTER_PACKETS_RECEIVED_TOTAL_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES, MOLECULER_TRANSPORTER_PACKETS_SENT_BYTES_DESC, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL, MOLECULER_TRANSPORTER_PACKETS_SENT_TOTAL_DESC

Constructor Summary

Constructors

Constructor and Description
DefaultEventbus()

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	broadcastInternal(Context ctx, Groups groups, boolean local)
protected void	checkTimeouts()
void	emit(Context ctx, Groups groups, boolean local)
protected void	emitInternal(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	isCheckVersion()
boolean	isWriteErrorsToLog()
protected void	logUnableToInvokeListener(java.lang.Throwable cause)
void	receiveEvent(io.datatree.Tree message)
void	removeListeners(java.lang.String nodeID)
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

checkVersion

protected boolean checkVersion

Check protocol version

protocolVersion

protected java.lang.String protocolVersion

ServiceBroker's 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

serviceInvoker

protected ServiceInvoker serviceInvoker

scheduler

protected java.util.concurrent.ScheduledExecutorService scheduler

uidGenerator

protected UidGenerator uidGenerator

metrics

protected Metrics metrics

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()

Method Detail

started

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

Initializes default EventBus instance.

Specified by:

started in interface MoleculerLifecycle

Overrides:

started in class MoleculerComponent

Parameters:

broker - parent ServiceBroker

Throws:

java.lang.Exception

stopped

public void stopped()

Specified by:

stopped in interface MoleculerLifecycle

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

emitInternal

protected void emitInternal(Context ctx,
                            Groups groups,
                            boolean local)

stopStreaming

protected void stopStreaming(Context ctx)

broadcast

public void broadcast(Context ctx,
                      Groups groups,
                      boolean local)

Specified by:

broadcast in class Eventbus

broadcastInternal

protected void broadcastInternal(Context ctx,
                                 Groups groups,
                                 boolean local)

logUnableToInvokeListener

protected void logUnableToInvokeListener(java.lang.Throwable cause)

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)

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)