@ManagedResource
@IntegrationManagedResource
public class RedisQueueMessageDrivenEndpoint
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.context.ApplicationEventPublisherAware
| Modifier and Type | Field and Description |
|---|---|
static long |
DEFAULT_RECEIVE_TIMEOUT |
static long |
DEFAULT_RECOVERY_INTERVAL |
lifecycleCondition, lifecycleLock| Constructor and Description |
|---|
RedisQueueMessageDrivenEndpoint(java.lang.String queueName,
org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) |
| Modifier and Type | Method and Description |
|---|---|
void |
clearQueue()
Clear the Redis Queue specified by
boundListOperations. |
protected void |
doStart() |
protected void |
doStop() |
protected void |
doStop(java.lang.Runnable callback) |
java.lang.String |
getComponentType() |
long |
getQueueSize()
Returns the size of the Queue specified by
boundListOperations. |
boolean |
isListening() |
protected void |
onInit() |
void |
setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher) |
void |
setErrorChannel(org.springframework.messaging.MessageChannel errorChannel) |
void |
setExpectMessage(boolean expectMessage)
When data is retrieved from the Redis queue, does the returned data represent
just the payload for a Message, or does the data represent a serialized
Message?. |
void |
setReceiveTimeout(long receiveTimeout)
This timeout (milliseconds) is used when retrieving elements from the queue
specified by
boundListOperations. |
void |
setRecoveryInterval(long recoveryInterval) |
void |
setRightPop(boolean rightPop)
Specify if
POP operation from Redis List should be BRPOP or BLPOP. |
void |
setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer) |
void |
setTaskExecutor(java.util.concurrent.Executor taskExecutor) |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrackdestroy, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toStringpublic static final long DEFAULT_RECEIVE_TIMEOUT
public static final long DEFAULT_RECOVERY_INTERVAL
public RedisQueueMessageDrivenEndpoint(java.lang.String queueName,
org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
queueName - Must not be an empty StringconnectionFactory - Must not be nullpublic void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAwarepublic void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
public void setExpectMessage(boolean expectMessage)
Message?. expectMessage defaults to false. This means
the retrieved data will be used as the payload for a new Spring Integration
Message. Otherwise, the data is deserialized as Spring Integration
Message.expectMessage - Defaults to falsepublic void setReceiveTimeout(long receiveTimeout)
boundListOperations.
If the queue does contain elements, the data is retrieved immediately. However, if the queue is empty, the Redis connection is blocked until either an element can be retrieved from the queue or until the specified timeout passes.
A timeout of zero can be used to block indefinitely. If not set explicitly
the timeout value will default to 1000
See also: http://redis.io/commands/brpop
receiveTimeout - Must be non-negative. Specified in milliseconds.public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)
public void setErrorChannel(org.springframework.messaging.MessageChannel errorChannel)
setErrorChannel in class org.springframework.integration.endpoint.MessageProducerSupportpublic void setRecoveryInterval(long recoveryInterval)
public void setRightPop(boolean rightPop)
POP operation from Redis List should be BRPOP or BLPOP.rightPop - the BRPOP flag. Defaults to true.protected void onInit()
onInit in class org.springframework.integration.endpoint.MessageProducerSupportpublic java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.context.IntegrationObjectSupportprotected void doStart()
doStart in class org.springframework.integration.endpoint.MessageProducerSupportprotected void doStop(java.lang.Runnable callback)
doStop in class org.springframework.integration.endpoint.AbstractEndpointprotected void doStop()
doStop in class org.springframework.integration.endpoint.MessageProducerSupportpublic boolean isListening()
@ManagedMetric public long getQueueSize()
boundListOperations. The queue is
represented by a Redis list. If the queue does not exist 0
is returned. See also http://redis.io/commands/llen@ManagedOperation public void clearQueue()
boundListOperations.