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.