org.springframework.integration.endpoint

Class MessageProducerSupport

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.endpoint.AbstractEndpoint

org.springframework.integration.endpoint.MessageProducerSupport

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, MessageProducer, TrackableComponent, NamedComponent

Direct Known Subclasses:

AbstractInboundFileSynchronizingMessageSource, AbstractInternetProtocolReceivingChannelAdapter, AbstractMqttMessageDrivenChannelAdapter, AbstractXmppConnectionAwareEndpoint, AmqpInboundChannelAdapter, ExpressionMessageProducerSupport, FileTailingMessageProducerSupport, ImapIdleChannelAdapter, NotificationListeningMessageProducer, RedisInboundChannelAdapter, RedisQueueMessageDrivenEndpoint, SyslogReceivingChannelAdapterSupport, TcpConnectionEventListeningMessageProducer, TcpReceivingChannelAdapter

public abstract class MessageProducerSupport
extends AbstractEndpoint
implements MessageProducer, TrackableComponent

A support class for producer endpoints that provides a setter for the output channel and a convenience method for sending Messages.

Author:

Mark Fisher, Artem Bilan

Field Summary

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

logger

Constructor Summary

Constructors

Constructor and Description
MessageProducerSupport()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	doStart() Takes no action by default.
protected void	doStop() Takes no action by default.
protected void	onInit() Subclasses may implement this for initialization logic.
protected void	sendMessage(Message<?> message)
void	setErrorChannel(MessageChannel errorChannel)
void	setOutputChannel(MessageChannel outputChannel) Specify the MessageChannel to which produced Messages should be sent.
void	setSendTimeout(long sendTimeout)
void	setShouldTrack(boolean shouldTrack)

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, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setConversionService, setMessageBuilderFactory, 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.support.context.NamedComponent

getComponentName, getComponentType

Constructor Detail

MessageProducerSupport

public MessageProducerSupport()

Method Detail

setOutputChannel

public void setOutputChannel(MessageChannel outputChannel)

Description copied from interface: MessageProducer

Specify the MessageChannel to which produced Messages should be sent.

Specified by:

setOutputChannel in interface MessageProducer

Parameters:

outputChannel - The output channel.

setErrorChannel

public void setErrorChannel(MessageChannel errorChannel)

setSendTimeout

public void setSendTimeout(long sendTimeout)

setShouldTrack

public void setShouldTrack(boolean shouldTrack)

Specified by:

setShouldTrack in interface TrackableComponent

onInit

protected void onInit()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

doStart

protected void doStart()

Takes no action by default. Subclasses may override this if they need lifecycle-managed behavior.

Specified by:

doStart in class AbstractEndpoint

doStop

protected void doStop()

Takes no action by default. Subclasses may override this if they need lifecycle-managed behavior.

Specified by:

doStop in class AbstractEndpoint

sendMessage

protected void sendMessage(Message<?> message)