Interface | Description |
---|---|
BackPressureContext |
Provides information about how the runtime applied back pressure on a certain
event |
ParameterizedSource |
A contract for obtaining the parameters that were configured into a
Source instance without depending
on its actual implementation class. |
PollContext<T,A> |
Contains context associated to each polling execution, and allows to dispatch items for execution through the
PollContext.accept(Consumer) method. |
PollContext.PollItem<T,A> |
An item obtained through a poll
|
SourceCallback<T,A> |
A callback to allow
Source implementations to communicate
generated messages back to the runtime so that they can be processed. |
SourceCallbackContext |
A context interface to correlate a message generated by a
Source to
a particular state |
SourceCompletionCallback |
Callback used by
sources in order tell the runtime that they will process the flow's response
in an asynchronous manner (from now on, async sources). |
SourceFactory |
Factory object for instances of
Source . |
Class | Description |
---|---|
PollingSource<T,A> |
A Special kind of
Source which automatically handles polling, idempotency and watermarking. |
Source<T,A> |
Base class to write message sources compliant with a given
SourceModel . |
SourceResult |
A class that represents the result of processing a message from a
Source through a flow,
this reports whether the result of the processing was successful or terminated with errors. |
Enum | Description |
---|---|
BackPressureAction |
Indicates which type of back pressure has the runtime applied on a give message.
|
BackPressureMode |
Describes the available back pressure strategies
|
PollContext.PollItemStatus |
The possible outcomes of submiting an item for processing through the
PollContext.accept(Consumer) method |
Copyright © 2018. All rights reserved.