Interface MessageDispatcherFactory

    • Method Detail

      • createSyncDispatcher

        <S extends Message,​T extends MessageSyncDispatcher<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 MessageAsyncDispatcher<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's AsyncPolicy.