APIdia Launch Partner
Top Inners Fields Constructors Methods
jdk.jfr.internal.consumer

pack-priv final Class Dispatcher

extends Object
Class Inheritance
Imports
java.time.Instant, java.util.ArrayList, .List, java.util.function.Consumer, jdk.jfr.EventType, jdk.jfr.consumer.MetadataEvent, .RecordedEvent, jdk.jfr.internal.LongMap, jdk.jfr.internal.consumer.ChunkParser.ParserConfiguration

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
Dispatcher.EventDispatcher

Field Summary

Modifier and TypeField and Description
private Dispatcher.EventDispatcher[]
cacheDispatchers

private EventType
cacheEventType

private final Runnable[]
closeActions

private final LongMap<Dispatcher.EventDispatcher[]>
dispatcherLookup

private final Dispatcher.EventDispatcher[]
dispatchers

pack-priv final long
endNanos

pack-priv final Instant
endTime

private final Consumer<Throwable>[]
errorActions

private final Runnable[]
flushActions

private final Consumer<MetadataEvent>[]
metadataActions

pack-priv final ChunkParser.ParserConfiguration
parserConfiguration

pack-priv final long
startNanos

pack-priv final Instant
startTime

Constructor Summary

AccessConstructor and Description
public
Dispatcher(StreamConfiguration c)

Method Summary

Modifier and TypeMethod and Description
private static ParserFilter
buildFilter(Dispatcher.EventDispatcher[] dispatchers)

private void
defaultErrorHandler(Throwable e)

pack-priv void
dispatch(RecordedEvent event)

private void
handleError(Throwable e)

public boolean
hasMetadataHandler()

public void
runCloseActions()

public void
runFlushActions()

public void
runMetadataActions(MetadataEvent event)

public String
toString()

Overrides java.lang.Object.toString.

Returns a string representation of the object.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAllwaitwaitwait

Field Detail

cacheDispatchersback to summary
private Dispatcher.EventDispatcher[] cacheDispatchers
cacheEventTypeback to summary
private EventType cacheEventType
closeActionsback to summary
private final Runnable[] closeActions
dispatcherLookupback to summary
private final LongMap<Dispatcher.EventDispatcher[]> dispatcherLookup
dispatchersback to summary
private final Dispatcher.EventDispatcher[] dispatchers
endNanosback to summary
pack-priv final long endNanos
endTimeback to summary
pack-priv final Instant endTime
errorActionsback to summary
private final Consumer<Throwable>[] errorActions
flushActionsback to summary
private final Runnable[] flushActions
metadataActionsback to summary
private final Consumer<MetadataEvent>[] metadataActions
parserConfigurationback to summary
pack-priv final ChunkParser.ParserConfiguration parserConfiguration
startNanosback to summary
pack-priv final long startNanos
startTimeback to summary
pack-priv final Instant startTime

Constructor Detail

Dispatcherback to summary
public Dispatcher(StreamConfiguration c)
Annotations
@SuppressWarnings:rawtypes, unchecked

Method Detail

buildFilterback to summary
private static ParserFilter buildFilter(Dispatcher.EventDispatcher[] dispatchers)
defaultErrorHandlerback to summary
private void defaultErrorHandler(Throwable e)
dispatchback to summary
pack-priv void dispatch(RecordedEvent event)
handleErrorback to summary
private void handleError(Throwable e)
hasMetadataHandlerback to summary
public boolean hasMetadataHandler()
runCloseActionsback to summary
public void runCloseActions()
runFlushActionsback to summary
public void runFlushActions()
runMetadataActionsback to summary
public void runMetadataActions(MetadataEvent event)
toStringback to summary
public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

jdk.jfr.internal.consumer back to summary

pack-priv final Class Dispatcher.EventDispatcher

extends Object
Class Inheritance

Field Summary

Modifier and TypeField and Description
private final Consumer<RecordedEvent>
action

private final String
eventName

private static final Dispatcher.EventDispatcher[]
NO_DISPATCHERS

Constructor Summary

AccessConstructor and Description
public
EventDispatcher(String eventName, Consumer<RecordedEvent> action)

Method Summary

Modifier and TypeMethod and Description
private boolean
accepts(EventType eventType)

public Consumer<RecordedEvent>
getAction()

private void
offer(RecordedEvent event)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

actionback to summary
private final Consumer<RecordedEvent> action
eventNameback to summary
private final String eventName
NO_DISPATCHERSback to summary
private static final Dispatcher.EventDispatcher[] NO_DISPATCHERS

Constructor Detail

EventDispatcherback to summary
public EventDispatcher(String eventName, Consumer<RecordedEvent> action)

Method Detail

acceptsback to summary
private boolean accepts(EventType eventType)
getActionback to summary
public Consumer<RecordedEvent> getAction()
offerback to summary
private void offer(RecordedEvent event)