public class ReactiveRedisStreamMessageHandler
extends org.springframework.integration.handler.AbstractReactiveMessageHandler
ReactiveMessageHandler which writes
Message payload or Message itself (see extractPayload) into a Redis stream using Reactive Stream operations.EXPRESSION_PARSER, logger| Constructor and Description |
|---|
ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory,
org.springframework.expression.Expression streamKeyExpression)
Create an instance based on provided
ReactiveRedisConnectionFactory and expression for stream key. |
ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory,
java.lang.String streamKey)
Create an instance based on provided
ReactiveRedisConnectionFactory and key for stream. |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getComponentType() |
protected reactor.core.publisher.Mono<java.lang.Void> |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected void |
onInit() |
void |
setExtractPayload(boolean extractPayload)
Set to
true to extract the payload; otherwise
the entire message is sent. |
void |
setHashMapper(org.springframework.data.redis.hash.HashMapper<java.lang.String,?,?> hashMapper)
(Optional) Set the
HashMapper used to create reactiveStreamOperations. |
void |
setSerializationContext(org.springframework.data.redis.serializer.RedisSerializationContext<java.lang.String,?> serializationContext) |
handleMessagebuildSendTimer, configureMetrics, destroy, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getHandlerMetrics, getIntegrationPatternType, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, isCountsEnabled, isLoggingEnabled, isStatsEnabled, registerMetricsCaptor, reset, sendTimer, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled, shouldTrackafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory,
java.lang.String streamKey)
ReactiveRedisConnectionFactory and key for stream.connectionFactory - the ReactiveRedisConnectionFactory to usestreamKey - the key for streampublic ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory,
org.springframework.expression.Expression streamKeyExpression)
ReactiveRedisConnectionFactory and expression for stream key.connectionFactory - the ReactiveRedisConnectionFactory to usestreamKeyExpression - the SpEL expression to evaluate a key for streampublic void setSerializationContext(org.springframework.data.redis.serializer.RedisSerializationContext<java.lang.String,?> serializationContext)
public void setHashMapper(@Nullable
org.springframework.data.redis.hash.HashMapper<java.lang.String,?,?> hashMapper)
HashMapper used to create reactiveStreamOperations.
The default HashMapper is defined from the provided RedisSerializationContexthashMapper - the wanted hashMapperpublic void setExtractPayload(boolean extractPayload)
true to extract the payload; otherwise
the entire message is sent. Default true.extractPayload - false to not extract.public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.handler.MessageHandlerSupportprotected void onInit()
onInit in class org.springframework.integration.handler.MessageHandlerSupportprotected reactor.core.publisher.Mono<java.lang.Void> handleMessageInternal(org.springframework.messaging.Message<?> message)
handleMessageInternal in class org.springframework.integration.handler.AbstractReactiveMessageHandler