Class RedisQueueInboundGatewaySpec

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<RedisQueueInboundGatewaySpec, RedisQueueInboundGateway>

org.springframework.integration.dsl.MessagingGatewaySpec<RedisQueueInboundGatewaySpec, RedisQueueInboundGateway>

org.springframework.integration.redis.dsl.RedisQueueInboundGatewaySpec

All Implemented Interfaces:

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

public class RedisQueueInboundGatewaySpec
extends MessagingGatewaySpec<RedisQueueInboundGatewaySpec, RedisQueueInboundGateway>

A MessagingGatewaySpec for a RedisQueueInboundGateway.

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

Method Summary

Modifier and Type	Method	Description
RedisQueueInboundGatewaySpec	extractPayload(boolean extractPayload)	Specify whether extract payload.
RedisQueueInboundGatewaySpec	receiveTimeout(long receiveTimeout)	Specify the receiveTimeout.
RedisQueueInboundGatewaySpec	receiveTimeout(Duration receiveTimeout)	Specify the receiveTimeout.
RedisQueueInboundGatewaySpec	recoveryInterval(long recoveryInterval)	Specify the time (in milliseconds) for the listener task should sleep after exceptions on the "right pop" operation before restarting the listener task.
RedisQueueInboundGatewaySpec	serializer(RedisSerializer<?> serializer)	Specify the redis serializer.
RedisQueueInboundGatewaySpec	taskExecutor(Executor taskExecutor)	Specify an Executor for the underlying listening task.

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

autoStartup, errorChannel, errorChannel, errorOnTimeout, id, observationConvention, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout, shouldTrack

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

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

RedisQueueInboundGatewaySpec

protected RedisQueueInboundGatewaySpec(String queueName,
 RedisConnectionFactory connectionFactory)

Method Details

extractPayload

public RedisQueueInboundGatewaySpec extractPayload(boolean extractPayload)

Specify whether extract payload.

Parameters:

extractPayload - the extractPayload

Returns:

the spec

See Also:

• RedisQueueInboundGateway.setExtractPayload(boolean)

serializer

public RedisQueueInboundGatewaySpec serializer(RedisSerializer<?> serializer)

Specify the redis serializer.

Parameters:

serializer - the serializer

Returns:

the spec

See Also:

• RedisQueueInboundGateway.setSerializer(RedisSerializer)

receiveTimeout

public RedisQueueInboundGatewaySpec receiveTimeout(Duration receiveTimeout)

Specify the receiveTimeout.

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec

See Also:

• RedisQueueInboundGateway.setReceiveDuration(Duration)

receiveTimeout

public RedisQueueInboundGatewaySpec receiveTimeout(long receiveTimeout)

Specify the receiveTimeout.

Parameters:

receiveTimeout - the receiveTimeout

Returns:

the spec

See Also:

• RedisQueueInboundGateway.setReceiveTimeout(long)

taskExecutor

public RedisQueueInboundGatewaySpec taskExecutor(Executor taskExecutor)

Specify an Executor for the underlying listening task.

Parameters:

taskExecutor - the taskExecutor

Returns:

the spec

See Also:

• RedisQueueInboundGateway.setTaskExecutor(Executor)

recoveryInterval

public RedisQueueInboundGatewaySpec recoveryInterval(long recoveryInterval)

Specify the time (in milliseconds) for the listener task should sleep after exceptions on the "right pop" operation before restarting the listener task.

Parameters:

recoveryInterval - the recoveryInterval

Returns:

the spec

See Also:

• RedisQueueInboundGateway.setRecoveryInterval(long)