Class RedisQueueInboundChannelAdapterSpec
java.lang.Object
org.springframework.integration.dsl.IntegrationComponentSpec<RedisQueueInboundChannelAdapterSpec, RedisQueueMessageDrivenEndpoint>
org.springframework.integration.dsl.MessageProducerSpec<RedisQueueInboundChannelAdapterSpec, RedisQueueMessageDrivenEndpoint>
org.springframework.integration.redis.dsl.RedisQueueInboundChannelAdapterSpec
- All Implemented Interfaces:
DisposableBean,FactoryBean<RedisQueueMessageDrivenEndpoint>,InitializingBean,Lifecycle,Phased,SmartLifecycle
public class RedisQueueInboundChannelAdapterSpec
extends MessageProducerSpec<RedisQueueInboundChannelAdapterSpec, RedisQueueMessageDrivenEndpoint>
- Since:
- 7.1
- Author:
- Jiandong Ma
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
logger, PARSER, targetFields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTEFields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE -
Constructor Summary
ConstructorsModifierConstructorDescriptionprotectedRedisQueueInboundChannelAdapterSpec(String queueName, RedisConnectionFactory connectionFactory) -
Method Summary
Modifier and TypeMethodDescriptionexpectMessage(boolean expectMessage) Specify whether expects data from the Redis queue to contain entire Message instances.receiveDuration(Duration receiveTimeout) Specify the timeout for 'pop' operation to wait for a Redis message from the Redis Queue.receiveTimeout(long receiveTimeout) Specify the timeout for 'pop' operation to wait for a Redis message from the Redis Queue.recoveryInterval(long recoveryInterval) Specify the time in milliseconds for the underlying listening task should sleep after exceptions on the 'pop' operation.rightPop(boolean rightPop) Specify use "right pop" or "left pop" to read messages from the Redis Queue.serializer(RedisSerializer<?> serializer) Specify the RedisSerializer to deserialize the body of Redis messages.taskExecutor(Executor taskExecutor) Specify anExecutorfor the underlying listening task.Methods inherited from class org.springframework.integration.dsl.MessageProducerSpec
autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, observationConvention, outputChannel, outputChannel, phase, role, sendTimeout, shouldTrackMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.beans.factory.FactoryBean
isSingletonMethods inherited from interface org.springframework.context.SmartLifecycle
isPauseable
-
Constructor Details
-
RedisQueueInboundChannelAdapterSpec
protected RedisQueueInboundChannelAdapterSpec(String queueName, RedisConnectionFactory connectionFactory)
-
-
Method Details
-
serializer
Specify the RedisSerializer to deserialize the body of Redis messages.- Parameters:
serializer- the serializer- Returns:
- the spec
- See Also:
-
expectMessage
Specify whether expects data from the Redis queue to contain entire Message instances.- Parameters:
expectMessage- the expectMessage- Returns:
- the spec
- See Also:
-
receiveDuration
Specify the timeout for 'pop' operation to wait for a Redis message from the Redis Queue.- Parameters:
receiveTimeout- the receiveTimeout- Returns:
- the spec
- See Also:
-
receiveTimeout
Specify the timeout for 'pop' operation to wait for a Redis message from the Redis Queue.- Parameters:
receiveTimeout- the receiveTimeout- Returns:
- the spec
- See Also:
-
taskExecutor
Specify anExecutorfor the underlying listening task.- Parameters:
taskExecutor- the taskExecutor- Returns:
- the spec
- See Also:
-
recoveryInterval
Specify the time in milliseconds for the underlying listening task should sleep after exceptions on the 'pop' operation.- Parameters:
recoveryInterval- the recoveryInterval- Returns:
- the spec
- See Also:
-
rightPop
Specify use "right pop" or "left pop" to read messages from the Redis Queue.- Parameters:
rightPop- the rightPop- Returns:
- the spec
- See Also:
-