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:
- BeanFactoryAware, BeanNameAware, InitializingBean, Lifecycle, Phased, SmartLifecycle, NamedComponent, MessageProducer, TrackableComponent
- Direct Known Subclasses:
- AbstractInternetProtocolReceivingChannelAdapter, ApplicationEventInboundChannelAdapter, ImapIdleChannelAdapter, NotificationListeningMessageProducer, ScheduledMessageProducer, 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
Methods inherited from class org.springframework.integration.endpoint.AbstractEndpoint |
doStart, doStop, getPhase, isAutoStartup, isRunning, setAutoStartup, setPhase, setTaskScheduler, start, stop, stop |
Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport |
afterPropertiesSet, getBeanFactory, getComponentName, getComponentType, getConversionService, getRequiredMetadataPersister, getTaskScheduler, setBeanFactory, setBeanName, setComponentName, setConversionService, toString |
MessageProducerSupport
public MessageProducerSupport()
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
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
sendMessage
protected void sendMessage(Message<?> message)
Copyright © 2010. All Rights Reserved.