Class ReactiveRedisStreamMessageHandler

All Implemented Interfaces:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Ordered, ExpressionCapable, Orderable, IntegrationPattern, NamedComponent, IntegrationManagement, TrackableComponent, ReactiveMessageHandler

public class ReactiveRedisStreamMessageHandler
extends AbstractReactiveMessageHandler
Implementation of ReactiveMessageHandler which writes Message payload or Message itself (see extractPayload) into a Redis stream using Reactive Stream operations.
Since:
5.4
Author:
Attoumane Ahamadi, Artem Bilan