Package org.springframework.integration.redis.dsl

Class RedisStreamOutboundChannelAdapterSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.MessageHandlerSpec<S,ReactiveMessageHandlerAdapter>

org.springframework.integration.dsl.ReactiveMessageHandlerSpec<RedisStreamOutboundChannelAdapterSpec,ReactiveRedisStreamMessageHandler>

org.springframework.integration.redis.dsl.RedisStreamOutboundChannelAdapterSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<ReactiveMessageHandlerAdapter>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration

public class RedisStreamOutboundChannelAdapterSpec
extends ReactiveMessageHandlerSpec<RedisStreamOutboundChannelAdapterSpec,ReactiveRedisStreamMessageHandler>

A ReactiveMessageHandlerSpec for a ReactiveRedisStreamMessageHandler.

Since:

7.1

Author:

Jiandong Ma

Field Summary

Fields inherited from class org.springframework.integration.dsl.ReactiveMessageHandlerSpec

reactiveMessageHandler

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RedisStreamOutboundChannelAdapterSpec(ReactiveRedisConnectionFactory connectionFactory, String streamKey)
protected	RedisStreamOutboundChannelAdapterSpec(ReactiveRedisConnectionFactory connectionFactory, Expression streamExpression)

Method Summary

Modifier and Type	Method	Description
RedisStreamOutboundChannelAdapterSpec	addOptionsFunction(Function<Message<?>,RedisStreamCommands.XAddOptions> addOptionsFunction)	Specify the function to create a RedisStreamCommands.XAddOptions.
RedisStreamOutboundChannelAdapterSpec	extractPayload(boolean extractPayload)	Specify whether extract payload.
RedisStreamOutboundChannelAdapterSpec	hashMapper(HashMapper<String,?,?> hashMapper)	Specify the hashMapper for ReactiveStreamOperations.
RedisStreamOutboundChannelAdapterSpec	serializationContext(RedisSerializationContext<String,?> serializationContext)	Specify the serialization context.

Methods inherited from class org.springframework.integration.dsl.ReactiveMessageHandlerSpec

getComponentsToRegister

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Methods inherited from interface org.springframework.context.SmartLifecycle

isPauseable

Constructor Details

RedisStreamOutboundChannelAdapterSpec

protected RedisStreamOutboundChannelAdapterSpec(ReactiveRedisConnectionFactory connectionFactory,
 String streamKey)

RedisStreamOutboundChannelAdapterSpec

protected RedisStreamOutboundChannelAdapterSpec(ReactiveRedisConnectionFactory connectionFactory,
 Expression streamExpression)

Method Details

serializationContext

public RedisStreamOutboundChannelAdapterSpec serializationContext(RedisSerializationContext<String,?> serializationContext)

Specify the serialization context.

Parameters:

serializationContext - the serializationContext

Returns:

the spec

See Also:

• ReactiveRedisStreamMessageHandler.setSerializationContext(RedisSerializationContext)

hashMapper

public RedisStreamOutboundChannelAdapterSpec hashMapper(HashMapper<String,?,?> hashMapper)

Specify the hashMapper for ReactiveStreamOperations.

Parameters:

hashMapper - the hashMapper

Returns:

the spec

See Also:

• ReactiveRedisStreamMessageHandler.setHashMapper(HashMapper)

extractPayload

public RedisStreamOutboundChannelAdapterSpec extractPayload(boolean extractPayload)

Specify whether extract payload.

Parameters:

extractPayload - the extractPayload

Returns:

the spec

See Also:

• ReactiveRedisStreamMessageHandler.setExtractPayload(boolean)

addOptionsFunction

public RedisStreamOutboundChannelAdapterSpec addOptionsFunction(Function<Message<?>,RedisStreamCommands.XAddOptions> addOptionsFunction)

Specify the function to create a RedisStreamCommands.XAddOptions.

Parameters:

addOptionsFunction - the addOptionsFunction

Returns:

the spec

See Also:

• ReactiveRedisStreamMessageHandler.setAddOptionsFunction(Function)