Class RedisQueueOutboundGatewaySpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<RedisQueueOutboundGatewaySpec, RedisQueueOutboundGateway>

org.springframework.integration.dsl.MessageHandlerSpec<RedisQueueOutboundGatewaySpec, RedisQueueOutboundGateway>

org.springframework.integration.redis.dsl.RedisQueueOutboundGatewaySpec

All Implemented Interfaces:

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

public class RedisQueueOutboundGatewaySpec
extends MessageHandlerSpec<RedisQueueOutboundGatewaySpec, RedisQueueOutboundGateway>

A MessageHandlerSpec for a RedisQueueOutboundGateway.

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	RedisQueueOutboundGatewaySpec(String queueName, RedisConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method	Description
RedisQueueOutboundGatewaySpec	extractPayload(boolean extractPayload)	Specify whether extract payload.
RedisQueueOutboundGatewaySpec	receiveTimeout(long receiveTimeout)	Specify the receiveTimeout.
RedisQueueOutboundGatewaySpec	receiveTimeout(Duration receiveTimeout)	Specify the receiveTimeout.
RedisQueueOutboundGatewaySpec	serializer(RedisSerializer<?> serializer)	Specify the redis serializer.

Methods inherited from class IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, id, 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

RedisQueueOutboundGatewaySpec

protected RedisQueueOutboundGatewaySpec(String queueName,
 RedisConnectionFactory connectionFactory)

Method Details

receiveTimeout

public RedisQueueOutboundGatewaySpec receiveTimeout(Duration receiveTimeout)

Specify the receiveTimeout.

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec

See Also:

• RedisQueueOutboundGateway.setReceiveDuration(Duration)

receiveTimeout

public RedisQueueOutboundGatewaySpec receiveTimeout(long receiveTimeout)

Specify the receiveTimeout.

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec

See Also:

• RedisQueueOutboundGateway.setReceiveTimeout(long)

extractPayload

public RedisQueueOutboundGatewaySpec extractPayload(boolean extractPayload)

Specify whether extract payload.

Parameters:

extractPayload - the extractPayload

Returns:

the spec

See Also:

• RedisQueueOutboundGateway.setExtractPayload(boolean)

serializer

public RedisQueueOutboundGatewaySpec serializer(RedisSerializer<?> serializer)

Specify the redis serializer.

Parameters:

serializer - the serializer

Returns:

the spec

See Also:

• RedisQueueOutboundGateway.setSerializer(RedisSerializer)