Class ReactiveStreamsConsumer

All Implemented Interfaces:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, IntegrationConsumer, NamedComponent, ManageableLifecycle, ManageableSmartLifecycle

public class ReactiveStreamsConsumer
extends AbstractEndpoint
implements IntegrationConsumer
An AbstractEndpoint implementation for Reactive Streams subscription into an input channel and reactive consumption of messages from that channel.
Since:
5.0
Author:
Artem Bilan