Uses of Interface
org.opennms.core.ipc.sink.api.SyncDispatcher
-
Packages that use SyncDispatcher Package Description org.opennms.core.ipc.sink.aggregation org.opennms.core.ipc.sink.api org.opennms.core.ipc.sink.common -
-
Uses of SyncDispatcher in org.opennms.core.ipc.sink.aggregation
Classes in org.opennms.core.ipc.sink.aggregation that implement SyncDispatcher Modifier and Type Class Description class
AggregatingSinkMessageProducer<S extends Message,T extends Message>
-
Uses of SyncDispatcher in org.opennms.core.ipc.sink.api
Methods in org.opennms.core.ipc.sink.api that return SyncDispatcher Modifier and Type Method Description <S extends Message,T extends Message>
SyncDispatcher<S>MessageDispatcherFactory. createSyncDispatcher(SinkModule<S,T> module)
Creates a new synchronous dispatcher that will lock the calling thread when dispatching messages. -
Uses of SyncDispatcher in org.opennms.core.ipc.sink.common
Methods in org.opennms.core.ipc.sink.common that return SyncDispatcher Modifier and Type Method Description <S extends Message,T extends Message>
SyncDispatcher<S>AbstractMessageDispatcherFactory. createSyncDispatcher(SinkModule<S,T> module)
protected <S extends Message,T extends Message>
SyncDispatcher<S>AbstractMessageDispatcherFactory. createSyncDispatcher(DispatcherState<W,S,T> state)
Constructors in org.opennms.core.ipc.sink.common with parameters of type SyncDispatcher Constructor Description AsyncDispatcherImpl(DispatcherState<W,S,T> state, AsyncPolicy asyncPolicy, SyncDispatcher<S> syncDispatcher)
-