| Class | Description |
|---|---|
| Boundary |
A
Boundary is a blocking utility that allows the user to bind an arbitrary number of Consumers to it. |
| DelegatingConsumer<T> | |
| Poller<T> | |
| Resequencer<T> |
A
Resequencer allows claimants to ensure proper ordering of replies by allocating long values from a
counter. |
| SingleUseConsumer<T> | |
| Tap<T> |
A
Tap provides a limited window into an event stream. |
| UriUtils |
Utility class for URI encoding and decoding based on RFC 3986.
|
| Exception | Description |
|---|---|
| CancelConsumerException |