| Package | Description |
|---|---|
| reactor.bus |
Hold the required abstraction to enable Event Driven Programming with Reactor.
|
| reactor.bus.routing | |
| reactor.bus.spec |
Specs help create
Reactors by providing a fluent API to specify
common options. |
| reactor.groovy.config |
| Modifier and Type | Method and Description |
|---|---|
Router |
EventBus.getRouter()
|
| Constructor and Description |
|---|
EventBus(Dispatcher dispatcher,
Router router)
Create a new Reactor that uses the given
Dispatcher. |
EventBus(Dispatcher dispatcher,
Router router,
Consumer<Throwable> dispatchErrorHandler,
Consumer<Throwable> uncaughtErrorHandler) |
EventBus(Registry<Object,Consumer<? extends Event<?>>> consumerRegistry,
Dispatcher dispatcher,
Router router,
Consumer<Throwable> dispatchErrorHandler,
Consumer<Throwable> uncaughtErrorHandler)
Create a new Reactor that uses the given
dispatacher and eventRouter. |
| Modifier and Type | Class and Description |
|---|---|
class |
ConsumerFilteringRouter
|
class |
TraceableDelegatingRouter |
| Constructor and Description |
|---|
TraceableDelegatingRouter(Router delegate) |
| Modifier and Type | Method and Description |
|---|---|
SPEC |
EventRoutingComponentSpec.eventRouter(Router router)
Assigns the component's EventRouter
|
| Modifier and Type | Class and Description |
|---|---|
class |
StreamRouter |
| Modifier and Type | Method and Description |
|---|---|
Router |
ReactorBuilder.getRouter() |
| Modifier and Type | Method and Description |
|---|---|
void |
ReactorBuilder.setRouter(Router value) |
Copyright © 2016. All rights reserved.