public class SwimlaneDispatcher extends Object
| Constructor and Description |
|---|
SwimlaneDispatcher(String subscriberId,
Integer swimlane,
Executor executor) |
| Modifier and Type | Method and Description |
|---|---|
CompletableFuture<?> |
dispatch(DispatchedEvent<Event> de,
Function<DispatchedEvent<Event>,CompletableFuture<?>> target) |
void |
processQueuedEvent() |
public CompletableFuture<?> dispatch(DispatchedEvent<Event> de, Function<DispatchedEvent<Event>,CompletableFuture<?>> target)
public void processQueuedEvent()
Copyright © 2019. All rights reserved.