Class ReactiveRedisStreamMessageHandler
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractReactiveMessageHandler
org.springframework.integration.redis.outbound.ReactiveRedisStreamMessageHandler
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.core.Ordered,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.context.Orderable,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.TrackableComponent,org.springframework.messaging.ReactiveMessageHandler
public class ReactiveRedisStreamMessageHandler
extends org.springframework.integration.handler.AbstractReactiveMessageHandler
Implementation of
ReactiveMessageHandler which writes
Message payload or Message itself (see extractPayload) into a Redis stream using Reactive Stream operations.- Since:
- 5.4
-
Nested Class Summary
-
Field Summary
Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, logger -
Constructor Summary
Constructors Constructor Description ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory, java.lang.String streamKey)Create an instance based on providedReactiveRedisConnectionFactoryand key for stream.ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory, org.springframework.expression.Expression streamKeyExpression)Create an instance based on providedReactiveRedisConnectionFactoryand expression for stream key. -
Method Summary
Modifier and Type Method Description java.lang.StringgetComponentType()protected reactor.core.publisher.Mono<java.lang.Void>handleMessageInternal(org.springframework.messaging.Message<?> message)protected voidonInit()voidsetExtractPayload(boolean extractPayload)Set totrueto extract the payload; otherwise the entire message is sent.voidsetHashMapper(org.springframework.data.redis.hash.HashMapper<java.lang.String,?,?> hashMapper)(Optional) Set theHashMapperused to createreactiveStreamOperations.voidsetSerializationContext(org.springframework.data.redis.serializer.RedisSerializationContext<java.lang.String,?> serializationContext)Methods inherited from class org.springframework.integration.handler.AbstractReactiveMessageHandler
handleMessageMethods inherited from class org.springframework.integration.handler.MessageHandlerSupport
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, 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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Constructor Details
-
ReactiveRedisStreamMessageHandler
public ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory, java.lang.String streamKey)Create an instance based on providedReactiveRedisConnectionFactoryand key for stream.- Parameters:
connectionFactory- theReactiveRedisConnectionFactoryto usestreamKey- the key for stream
-
ReactiveRedisStreamMessageHandler
public ReactiveRedisStreamMessageHandler(org.springframework.data.redis.connection.ReactiveRedisConnectionFactory connectionFactory, org.springframework.expression.Expression streamKeyExpression)Create an instance based on providedReactiveRedisConnectionFactoryand expression for stream key.- Parameters:
connectionFactory- theReactiveRedisConnectionFactoryto usestreamKeyExpression- the SpEL expression to evaluate a key for stream
-
-
Method Details
-
setSerializationContext
public void setSerializationContext(org.springframework.data.redis.serializer.RedisSerializationContext<java.lang.String,?> serializationContext) -
setHashMapper
public void setHashMapper(@Nullable org.springframework.data.redis.hash.HashMapper<java.lang.String,?,?> hashMapper)(Optional) Set theHashMapperused to createreactiveStreamOperations. The defaultHashMapperis defined from the providedRedisSerializationContext- Parameters:
hashMapper- the wanted hashMapper
-
setExtractPayload
public void setExtractPayload(boolean extractPayload)Set totrueto extract the payload; otherwise the entire message is sent. Defaulttrue.- Parameters:
extractPayload- false to not extract.
-
getComponentType
public java.lang.String getComponentType()- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.handler.MessageHandlerSupport
-
onInit
protected void onInit()- Overrides:
onInitin classorg.springframework.integration.context.IntegrationObjectSupport
-
handleMessageInternal
protected reactor.core.publisher.Mono<java.lang.Void> handleMessageInternal(org.springframework.messaging.Message<?> message)- Specified by:
handleMessageInternalin classorg.springframework.integration.handler.AbstractReactiveMessageHandler
-