Search Java Classes and Packages
#Reactor.bus Classes and Interfaces - 43 results found.
| Name | Description | Type | Package | Framework |
| Bus | Basic unit of event handling in Reactor. | Interface | reactor.bus | Reactor |
| BusPublisher | Emit signals whenever an Event arrives from the Selector topic from the Bus. | Class | reactor.bus.publisher | Reactor |
| CachableRegistration | Class | reactor.bus.registry | Reactor | |
| CachingRegistry | Class | reactor.bus.registry | Reactor | |
| CallbackEvent | Simple Event implementation that attaches a callback to an Event and passes it to a delegate Consumer. | Class | reactor.bus.support | Reactor |
| ClassSelector | Class | reactor.bus.selector | Reactor | |
| ConsumerFilteringRouter | An Router that filters consumers before routing events toAuthor:Andy Wilkinson, Stephane Maldini | Class | reactor.bus.routing | Reactor |
| DispatcherComponentSpec | A generic environment-aware class for specifying components that need to be configured with an Environment and Dispatcher. | Class | reactor.bus.spec | Reactor |
| Event | Wrapper for an object that needs to be processed by Consumers. | Class | reactor.bus | Reactor |
| Event .Headers | Headers are a Map-like structure of name-value pairs. | Class | reactor.bus | Reactor |
| EventBus | A reactor is an event gateway that allows other components to register Event Consumers that can subsequently be notified of events. | Class | reactor.bus | Reactor |
| EventBus .ReplyToEvent | Class | reactor.bus | Reactor | |
| EventBusSpec | A helper class for configuring a new EventBus. | Class | reactor.bus.spec | Reactor |
| EventConsumer | Simple Consumer implementation that pulls the data from an Event and passes it to a delegate Consumer. | Class | reactor.bus.support | Reactor |
| EventRoutingComponentSpec | A generic environment-aware class for specifying components that need to be configured with an Environment, Dispatcher, and Router. | Class | reactor.bus.spec | Reactor |
| EventRoutingComponentSpec .EventRoutingStrategy | Returns the enum constant of this type with the specified name. | Class | reactor.bus.spec | Reactor |
| EventTimer | A hashed wheel timer implementation that uses a Registry and custom Selectors to determine when tasks should be executed. | Class | reactor.bus.timer | Reactor |
| Filter | A Filter is used to filter a list of items. | Interface | reactor.bus.filter | Reactor |
| FirstFilter | A Filter implementation that returns the first item. | Class | reactor.bus.filter | Reactor |
| HeaderResolver | Responsible for extracting any applicable headers from a key. | Interface | reactor.bus.selector | Reactor |
| JsonPathSelector | Class | reactor.bus.selector | Reactor | |
| MatchAllSelector | Class | reactor.bus.selector | Reactor | |
| NotifyConsumer | A Consumer that notifies an observable of each value that it has accepted. | Class | reactor.bus.support | Reactor |
| ObjectSelector | Selector implementation that uses the Object. | Class | reactor.bus.selector | Reactor |
| PassThroughFilter | A Filter implementation that performs no filtering, returning the items as-is. | Class | reactor.bus.filter | Reactor |
| PredicateSelector | Class | reactor.bus.selector | Reactor | |
| RandomFilter | A Filter implementation that returns a single, randomly selected item. | Class | reactor.bus.filter | Reactor |
| RegexSelector | A Selector implementation based on the given regular expression. | Class | reactor.bus.selector | Reactor |
| Registration | A Registration represents an object that has been registered with a Registry. | Interface | reactor.bus.registry | Reactor |
| Registries | Class | reactor.bus.registry | Reactor | |
| Registry | use simple keys, they use Selectors to map their objects. | Interface | reactor.bus.registry | Reactor |
| RoundRobinFilter | A Filter implementation that returns a single item. | Class | reactor.bus.filter | Reactor |
| Router | An Router is used to route an Object to Consumers. | Interface | reactor.bus.routing | Reactor |
| Selector | A Selector is a wrapper around an arbitrary object. | Interface | reactor.bus.selector | Reactor |
| Selectors | Helper methods for creating Selectors. | Class | reactor.bus.selector | Reactor |
| Selectors .AnonymousKey | Class | reactor.bus.selector | Reactor | |
| SetMembershipSelector | objects on set membership. | Class | reactor.bus.selector | Reactor |
| SimpleCachingRegistry | A naive caching Registry implementation for use in situations that the default CachingRegistry can't be used due to its reliance on the gs-collections library. | Class | reactor.bus.registry | Reactor |
| TraceableDelegatingFilter | Class | reactor.bus.filter | Reactor | |
| TraceableDelegatingRouter | Class | reactor.bus.routing | Reactor | |
| UriPathSelector | A Selector implementation based on a UriPathTemplate. | Class | reactor.bus.selector | Reactor |
| UriPathTemplate | Represents a URI template. | Class | reactor.bus.selector | Reactor |
| UriSelector | A Selector implementation that matches on various components of a full URI. | Class | reactor.bus.selector | Reactor |