Package org.opennms.core.ipc.sink.api
Interface MessageDispatcherFactory
-
- All Known Implementing Classes:
AbstractMessageDispatcherFactory
,AmazonSQSLocalMessageDispatcherFactory
,AmazonSQSRemoteMessageDispatcherFactory
,CamelLocalMessageDispatcherFactory
,CamelRemoteMessageDispatcherFactory
,GrpcLocalDispatcherFactory
,KafkaLocalMessageDispatcherFactory
,KafkaRemoteMessageDispatcherFactory
,MinionGrpcClient
,MockMessageDispatcherFactory
,OsgiLocalDispatcherFactory
public interface MessageDispatcherFactory
Generates a dispatcher for the givenSinkModule
.- Author:
- jwhite
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description <S extends Message,T extends Message>
AsyncDispatcher<S>createAsyncDispatcher(SinkModule<S,T> module)
Creates a new dispatcher used to send messages asynchronously.<S extends Message,T extends Message>
SyncDispatcher<S>createSyncDispatcher(SinkModule<S,T> module)
Creates a new synchronous dispatcher that will lock the calling thread when dispatching messages.
-
-
-
Method Detail
-
createSyncDispatcher
<S extends Message,T extends Message> SyncDispatcher<S> createSyncDispatcher(SinkModule<S,T> module)
Creates a new synchronous dispatcher that will lock the calling thread when dispatching messages.
-
createAsyncDispatcher
<S extends Message,T extends Message> AsyncDispatcher<S> createAsyncDispatcher(SinkModule<S,T> module)
Creates a new dispatcher used to send messages asynchronously. The behavior of the asynchronous dispatcher is defined by the module'sAsyncPolicy
.
-
-