public class RedisQueueOutboundChannelAdapter extends AbstractMessageHandler
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
RedisQueueOutboundChannelAdapter(org.springframework.expression.Expression queueNameExpression,
org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) |
RedisQueueOutboundChannelAdapter(java.lang.String queueName,
org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setExtractPayload(boolean extractPayload) |
void |
setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext) |
void |
setLeftPush(boolean leftPush)
Specify if
PUSH operation to Redis List should be LPUSH or RPUSH . |
void |
setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer) |
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, 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 RedisQueueOutboundChannelAdapter(java.lang.String queueName, org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public RedisQueueOutboundChannelAdapter(org.springframework.expression.Expression queueNameExpression, org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public void setExtractPayload(boolean extractPayload)
public void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
public void setLeftPush(boolean leftPush)
PUSH
operation to Redis List should be LPUSH
or RPUSH
.leftPush
- the LPUSH
flag. Defaults to true
.public void setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
protected void onInit() throws java.lang.Exception
IntegrationObjectSupport
onInit
in class AbstractMessageHandler
java.lang.Exception
- Any exception.protected void handleMessageInternal(org.springframework.messaging.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class AbstractMessageHandler
java.lang.Exception