public class DefaultEventbus extends Eventbus implements MetricConstants
| 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
|
broker, logger, nameMOLECULER_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 and Description |
|---|
DefaultEventbus() |
| 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) |
getBroker, getLogger, getNameprotected final java.util.HashMap<java.lang.String,java.util.HashMap<java.lang.String,Strategy<ListenerEndpoint>>> listeners
protected final io.datatree.dom.Cache<java.lang.String,Strategy<ListenerEndpoint>[]> emitterCache
protected final io.datatree.dom.Cache<java.lang.String,ListenerEndpoint[]> broadcasterCache
protected final io.datatree.dom.Cache<java.lang.String,ListenerEndpoint[]> localBroadcasterCache
protected boolean checkVersion
protected java.lang.String protocolVersion
protected java.lang.String nodeID
protected boolean writeErrorsToLog
protected long streamTimeout
protected int maxCallLevel
protected final java.util.concurrent.locks.Lock registryReadLock
protected final java.util.concurrent.locks.Lock registryWriteLock
protected java.util.concurrent.ScheduledFuture<?> streamTimeoutTimer
protected StrategyFactory strategy
protected Transporter transporter
protected ServiceInvoker serviceInvoker
protected java.util.concurrent.ScheduledExecutorService scheduler
protected UidGenerator uidGenerator
protected Metrics metrics
protected final java.util.HashMap<java.lang.String,IncomingStream> requestStreams
protected final java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock requestStreamReadLock
protected final java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock requestStreamWriteLock
public void started(ServiceBroker broker) throws java.lang.Exception
started in interface MoleculerLifecyclestarted in class MoleculerComponentbroker - parent ServiceBrokerjava.lang.Exceptionpublic void stopped()
stopped in interface MoleculerLifecyclestopped in class MoleculerComponentprotected void checkTimeouts()
public void receiveEvent(io.datatree.Tree message)
receiveEvent in class Eventbuspublic void addListeners(java.lang.String serviceName,
Service service)
addListeners in class Eventbuspublic void addListeners(java.lang.String nodeID,
io.datatree.Tree config)
addListeners in class Eventbuspublic void removeListeners(java.lang.String nodeID)
removeListeners in class Eventbusprotected void stopStreaming(Context ctx)
protected void logUnableToInvokeListener(java.lang.Throwable cause)
protected java.lang.String getCacheKey(java.lang.String name,
Groups groups)
public io.datatree.Tree generateListenerDescriptor(java.lang.String service)
generateListenerDescriptor in class Eventbuspublic boolean isCheckVersion()
public void setCheckVersion(boolean checkVersion)
public boolean isWriteErrorsToLog()
public void setWriteErrorsToLog(boolean writeErrorsToLog)
public long getStreamTimeout()
public void setStreamTimeout(long streamTimeout)
public int getMaxCallLevel()
public void setMaxCallLevel(int maxCallLevel)