com.networknt.eventuate.event

Class SwimlaneDispatcher

java.lang.Object

com.networknt.eventuate.event.SwimlaneDispatcher

public class SwimlaneDispatcher
extends Object

Constructor Summary

Constructors

Constructor and Description
SwimlaneDispatcher(String subscriberId, Integer swimlane, Executor executor)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<?>	dispatch(DispatchedEvent<Event> de, Function<DispatchedEvent<Event>,CompletableFuture<?>> target)
void	processQueuedEvent()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SwimlaneDispatcher

public SwimlaneDispatcher(String subscriberId,
                          Integer swimlane,
                          Executor executor)

Method Detail

dispatch

public CompletableFuture<?> dispatch(DispatchedEvent<Event> de,
                                     Function<DispatchedEvent<Event>,CompletableFuture<?>> target)

processQueuedEvent

public void processQueuedEvent()