public class RedisQueueOutboundGateway extends AbstractReplyProducingMessageHandler
AbstractReplyProducingMessageHandler.RequestHandler
messagingTemplate
EXPRESSION_PARSER, logger
Constructor and Description |
---|
RedisQueueOutboundGateway(String queueName,
org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected Object |
handleRequestMessage(org.springframework.messaging.Message<?> message)
Subclasses must implement this method to handle the request Message.
|
void |
setExtractPayload(boolean extractPayload) |
void |
setReceiveTimeout(int timeout) |
void |
setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer) |
doInit, doInvokeAdvisedRequestHandler, getRequiresReply, handleMessageInternal, hasAdviceChain, onInit, setAdviceChain, setBeanClassLoader, setRequiresReply
addNotPropagatedHeaders, createOutputMessage, getNotPropagatedHeaders, getOutputChannel, isAsync, produceOutput, resolveErrorChannel, sendErrorMessage, sendOutput, sendOutputs, setAsync, setNotPropagatedHeaders, setOutputChannel, setOutputChannelName, setSendTimeout, shouldCopyRequestHeaders, shouldSplitOutput
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public RedisQueueOutboundGateway(String queueName, org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public void setReceiveTimeout(int timeout)
public void setExtractPayload(boolean extractPayload)
public void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
public String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
protected Object handleRequestMessage(org.springframework.messaging.Message<?> message)
AbstractReplyProducingMessageHandler
handleRequestMessage
in class AbstractReplyProducingMessageHandler
message
- The request message.null
.