org.springframework.integration.x.redis

Class RedisQueueInboundChannelAdapter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

org.springframework.integration.x.redis.RedisQueueInboundChannelAdapter

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, org.springframework.integration.context.NamedComponent, org.springframework.integration.core.MessageProducer, org.springframework.integration.history.TrackableComponent

public class RedisQueueInboundChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport

Author:

Mark Fisher

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

logger

Constructor Summary

Constructors

Constructor and Description
RedisQueueInboundChannelAdapter(java.lang.String queueName, org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart()
protected void	doStop()
protected void	onInit()
void	setExtractPayload(boolean extractPayload)

Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport

sendMessage, setErrorChannel, setOutputChannel, setSendTimeout, setShouldTrack

Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint

getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getComponentType, getConversionService, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.context.NamedComponent

getComponentName, getComponentType

Constructor Detail

RedisQueueInboundChannelAdapter

public RedisQueueInboundChannelAdapter(java.lang.String queueName,
                               org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

Method Detail

setExtractPayload

public void setExtractPayload(boolean extractPayload)

onInit

protected void onInit()

Overrides:

onInit in class org.springframework.integration.endpoint.MessageProducerSupport

doStart

protected void doStart()

Overrides:

doStart in class org.springframework.integration.endpoint.MessageProducerSupport

doStop

protected void doStop()

Overrides:

doStop in class org.springframework.integration.endpoint.MessageProducerSupport