Class RedisOutboundChannelAdapterSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<RedisOutboundChannelAdapterSpec, RedisPublishingMessageHandler>

org.springframework.integration.dsl.MessageHandlerSpec<RedisOutboundChannelAdapterSpec, RedisPublishingMessageHandler>

org.springframework.integration.redis.dsl.RedisOutboundChannelAdapterSpec

All Implemented Interfaces:

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

public class RedisOutboundChannelAdapterSpec
extends MessageHandlerSpec<RedisOutboundChannelAdapterSpec, RedisPublishingMessageHandler>

A MessageHandlerSpec for a RedisPublishingMessageHandler.

Since:

7.1

Author:

Jiandong Ma

Field Summary

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	RedisOutboundChannelAdapterSpec(RedisConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
RedisOutboundChannelAdapterSpec	messageConverter(MessageConverter messageConverter)	Specify the messageConverter to convert between Redis messages and Spring message payloads.
RedisOutboundChannelAdapterSpec	serializer(RedisSerializer<?> serializer)	Specify the RedisSerializer to serialize data before sending to the Redis.
RedisOutboundChannelAdapterSpec	topic(String topic)	Specify the topic to publish messages.
RedisOutboundChannelAdapterSpec	topicExpression(String topicExpression)	Configure a SpEL expression to determine the topic.
RedisOutboundChannelAdapterSpec	topicExpression(Expression topicExpression)	Specify the topicExpression to determine the topic.
<P> RedisOutboundChannelAdapterSpec	topicFunction(Function<Message<P>, String> topicFunction)	Configure a Function to determine the topic.

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

RedisOutboundChannelAdapterSpec

protected RedisOutboundChannelAdapterSpec(RedisConnectionFactory connectionFactory)

Method Details

serializer

public RedisOutboundChannelAdapterSpec serializer(RedisSerializer<?> serializer)

Specify the RedisSerializer to serialize data before sending to the Redis.

Parameters:

serializer - the serializer

Returns:

the spec

See Also:

• RedisPublishingMessageHandler.setSerializer(RedisSerializer)

messageConverter

public RedisOutboundChannelAdapterSpec messageConverter(MessageConverter messageConverter)

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

Parameters:

messageConverter - the messageConverter

Returns:

the spec

See Also:

• RedisPublishingMessageHandler.setMessageConverter(MessageConverter)

topic

public RedisOutboundChannelAdapterSpec topic(String topic)

Specify the topic to publish messages.

Parameters:

topic - the topic

Returns:

the spec

See Also:

• RedisPublishingMessageHandler.setTopic(String)

topicExpression

public RedisOutboundChannelAdapterSpec topicExpression(Expression topicExpression)

Specify the topicExpression to determine the topic.

Parameters:

topicExpression - the topicExpression

Returns:

the spec

See Also:

• RedisPublishingMessageHandler.setTopicExpression(Expression)

topicExpression

public RedisOutboundChannelAdapterSpec topicExpression(String topicExpression)

Configure a SpEL expression to determine the topic.

Parameters:

topicExpression - the topicExpression

Returns:

the spec

See Also:

• RedisPublishingMessageHandler.setTopicExpression(Expression)

topicFunction

public <P> RedisOutboundChannelAdapterSpec topicFunction(Function<Message<P>, String> topicFunction)

Configure a Function to determine the topic.

Type Parameters:

P - the payload type.

Parameters:

topicFunction - the topicFunction

Returns:

the spec