public final class EventMultiplexerPassThrough extends EventMultiplexer
In a pass through multiplexer, the threads carrying the events from the sources pass directly and concurrently through the multiplexer. It should be noted that a fundamental tenet of a multiplexer is that the registered event handler cannot be concurrently invoked. Therefore, implicit in the semantic of this multiplexer implementation is the assumption that the caller will not be concurrently multiplexing events through the multiplexer.
IEventMultiplexer.State
captureEventLatencyStats
NON_BLOCKING
Modifier and Type | Method and Description |
---|---|
static IEventMultiplexer |
create(String name,
boolean administrative,
IEventHandler eventHandler,
Properties props)
Create a pass through event multiplexer.
|
IEventMultiplexerStats |
getStats()
Implementation of
IEventMultiplexer.getStats() |
close, getName, multiplexEvent, onEvent, onEvent, open, scheduledEventCount, scheduleEvent, setAllEventDispatch, unscheduleEvent
getChecked, getThreaded, getTracer, setChecked, setTracer
public static IEventMultiplexer create(String name, boolean administrative, IEventHandler eventHandler, Properties props)
name
- The event multiplexer's nameadministrative
- Whether this multiplexer is an administrative one
i.e. not subject to auto performance tuning.eventHandler
- The dispatch event handler i.e. the event handler
through which multiplexed events are dispatched.props
- A set of properties that qualify the behavior multiplexer
behavior. The pass through multiplexer does not currently support any
properties for its use.public final IEventMultiplexerStats getStats()
IEventMultiplexer.getStats()
Copyright © 2019 Neeve Research, LLC. All Rights Reserved.