Class RedisQueueOutboundChannelAdapterSpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<RedisQueueOutboundChannelAdapterSpec, RedisQueueOutboundChannelAdapter>

org.springframework.integration.dsl.MessageHandlerSpec<RedisQueueOutboundChannelAdapterSpec, RedisQueueOutboundChannelAdapter>

org.springframework.integration.redis.dsl.RedisQueueOutboundChannelAdapterSpec

All Implemented Interfaces:

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

public class RedisQueueOutboundChannelAdapterSpec
extends MessageHandlerSpec<RedisQueueOutboundChannelAdapterSpec, RedisQueueOutboundChannelAdapter>

A MessageHandlerSpec for a RedisQueueOutboundChannelAdapter.

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	RedisQueueOutboundChannelAdapterSpec(String queueName, RedisConnectionFactory connectionFactory)
protected	RedisQueueOutboundChannelAdapterSpec(Expression queueExpression, RedisConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
RedisQueueOutboundChannelAdapterSpec	extractPayload(boolean extractPayload)	Specify send only the payload or the entire Message to the Redis queue.
RedisQueueOutboundChannelAdapterSpec	leftPush(boolean leftPush)	Specify use "left push" or "right push" to write messages to the Redis Queue.
RedisQueueOutboundChannelAdapterSpec	serializer(RedisSerializer<?> serializer)	Specify the RedisSerializer to serialize data before sending to the Redis Queue.

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

RedisQueueOutboundChannelAdapterSpec

protected RedisQueueOutboundChannelAdapterSpec(String queueName,
 RedisConnectionFactory connectionFactory)

RedisQueueOutboundChannelAdapterSpec

protected RedisQueueOutboundChannelAdapterSpec(Expression queueExpression,
 RedisConnectionFactory connectionFactory)

Method Details

extractPayload

public RedisQueueOutboundChannelAdapterSpec extractPayload(boolean extractPayload)

Specify send only the payload or the entire Message to the Redis queue.

Parameters:

extractPayload - the extractPayload

Returns:

the spec

See Also:

• RedisQueueOutboundChannelAdapter.setExtractPayload(boolean)

serializer

public RedisQueueOutboundChannelAdapterSpec serializer(RedisSerializer<?> serializer)

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

Parameters:

serializer - the serializer

Returns:

the spec

See Also:

• RedisQueueOutboundChannelAdapter.setSerializer(RedisSerializer)

leftPush

public RedisQueueOutboundChannelAdapterSpec leftPush(boolean leftPush)

Specify use "left push" or "right push" to write messages to the Redis Queue.

Parameters:

leftPush - the leftPush

Returns:

the spec

See Also:

• RedisQueueOutboundChannelAdapter.setLeftPush(boolean)