public class RedisInboundChannelAdapter extends MessageProducerSupport
logger
Constructor and Description |
---|
RedisInboundChannelAdapter(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
doStart()
Takes no action by default.
|
protected void |
doStop()
Takes no action by default.
|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setMessageConverter(MessageConverter messageConverter) |
void |
setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer) |
void |
setTopicPatterns(java.lang.String... topicPatterns) |
void |
setTopics(java.lang.String... topics) |
sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack
getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop
afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public RedisInboundChannelAdapter(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public void setSerializer(org.springframework.data.redis.serializer.RedisSerializer<?> serializer)
public void setTopics(java.lang.String... topics)
public void setTopicPatterns(java.lang.String... topicPatterns)
public void setMessageConverter(MessageConverter messageConverter)
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class IntegrationObjectSupport
protected void onInit()
IntegrationObjectSupport
onInit
in class MessageProducerSupport
protected void doStart()
MessageProducerSupport
doStart
in class MessageProducerSupport
protected void doStop()
MessageProducerSupport
doStop
in class MessageProducerSupport