| Package | Description |
|---|---|
| reactor.bus.filter |
Filters eliminate components from a list based on a predicate.
|
| 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 | Class and Description |
|---|---|
class |
FirstFilter
A
Filter implementation that returns the first item. |
class |
PassThroughFilter
A
Filter implementation that performs no filtering, returning the items as-is. |
class |
RandomFilter
A
Filter implementation that returns a single, randomly selected item. |
class |
RoundRobinFilter
A
Filter implementation that returns a single item. |
class |
TraceableDelegatingFilter |
| Constructor and Description |
|---|
TraceableDelegatingFilter(Filter delegate) |
| Modifier and Type | Method and Description |
|---|---|
Filter |
ConsumerFilteringRouter.getFilter()
Returns the
Filter being used |
| Constructor and Description |
|---|
ConsumerFilteringRouter(Filter filter)
Creates a new
ConsumerFilteringEventRouter that will use the filter to filter consumers. |
| Modifier and Type | Method and Description |
|---|---|
SPEC |
EventRoutingComponentSpec.eventFilter(Filter filter)
Assigns the component's Filter
|
| Modifier and Type | Method and Description |
|---|---|
Filter |
ReactorBuilder.getFilter() |
Filter |
ReactorBuilder.routingStrategy(String strategy) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReactorBuilder.setFilter(Filter value) |
| Constructor and Description |
|---|
StreamRouter(Filter filter,
Registry<Object,org.reactivestreams.Processor<Event<?>,Event<?>>> processorRegistry) |
Copyright © 2016. All rights reserved.