Class RedisInboundChannelAdapterSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<RedisInboundChannelAdapterSpec, RedisInboundChannelAdapter>

org.springframework.integration.dsl.MessageProducerSpec<RedisInboundChannelAdapterSpec, RedisInboundChannelAdapter>

org.springframework.integration.redis.dsl.RedisInboundChannelAdapterSpec

All Implemented Interfaces:

DisposableBean, FactoryBean<RedisInboundChannelAdapter>, InitializingBean, Lifecycle, Phased, SmartLifecycle

public class RedisInboundChannelAdapterSpec
extends MessageProducerSpec<RedisInboundChannelAdapterSpec, RedisInboundChannelAdapter>

A MessageProducerSpec for a RedisInboundChannelAdapter.

Since:

7.1

Author:

Jiandong Ma

Field Summary

Fields inherited from class IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RedisInboundChannelAdapterSpec(RedisConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
RedisInboundChannelAdapterSpec	messageConverter(MessageConverter messageConverter)	Specify the messageConverter to convert between Redis messages and Spring message payloads.
RedisInboundChannelAdapterSpec	serializer(RedisSerializer<?> serializer)	Specify the RedisSerializer to deserialize the body of Redis messages.
RedisInboundChannelAdapterSpec	taskExecutor(Executor taskExecutor)	Specify an Executor for running the message listeners when messages are received.
RedisInboundChannelAdapterSpec	topicPatterns(String... topicPatterns)	Specify the topicPatterns to subscribe.
RedisInboundChannelAdapterSpec	topics(String... topics)	Specify the topics to subscribe.

Methods inherited from class MessageProducerSpec

autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, observationConvention, outputChannel, outputChannel, phase, role, sendTimeout, shouldTrack

Methods inherited from class IntegrationComponentSpec

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

Methods inherited from class Object

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

Methods inherited from interface FactoryBean

isSingleton

Methods inherited from interface SmartLifecycle

isPauseable

Constructor Details

RedisInboundChannelAdapterSpec

protected RedisInboundChannelAdapterSpec(RedisConnectionFactory connectionFactory)

Method Details

serializer

public RedisInboundChannelAdapterSpec serializer(RedisSerializer<?> serializer)

Specify the RedisSerializer to deserialize the body of Redis messages.

Parameters:

serializer - the serializer

Returns:

the spec

See Also:

• RedisInboundChannelAdapter.setSerializer(RedisSerializer)

topics

public RedisInboundChannelAdapterSpec topics(String... topics)

Specify the topics to subscribe.

Parameters:

topics - the topics

Returns:

the spec

See Also:

• RedisInboundChannelAdapter.setTopics(String...)

topicPatterns

public RedisInboundChannelAdapterSpec topicPatterns(String... topicPatterns)

Specify the topicPatterns to subscribe.

Parameters:

topicPatterns - the topicPatterns

Returns:

the spec

See Also:

• RedisInboundChannelAdapter.setTopicPatterns(String...)

messageConverter

public RedisInboundChannelAdapterSpec messageConverter(MessageConverter messageConverter)

Specify the messageConverter to convert between Redis messages and Spring message payloads.

Parameters:

messageConverter - the messageConverter

Returns:

the spec

See Also:

• RedisInboundChannelAdapter.setMessageConverter(MessageConverter)

taskExecutor

public RedisInboundChannelAdapterSpec taskExecutor(Executor taskExecutor)

Specify an Executor for running the message listeners when messages are received.

Parameters:

taskExecutor - the taskExecutor

Returns:

the spec

See Also:

• RedisInboundChannelAdapter.setTaskExecutor(Executor)