org.springframework.integration.adapter
Class AbstractSourceAdapter<T>

java.lang.Object
  org.springframework.integration.adapter.AbstractSourceAdapter<T>

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, SourceAdapter

Direct Known Subclasses:

ApplicationEventSourceAdapter, JmsMessageDrivenSourceAdapter, PollingSourceAdapter

public abstract class AbstractSourceAdapter<T>
extends java.lang.Object
implements SourceAdapter, org.springframework.beans.factory.InitializingBean

A base class providing common behavior for source adapters.

Author:

Mark Fisher

Field Summary

protected org.apache.commons.logging.Log

logger

Constructor Summary

AbstractSourceAdapter()

Method Summary

void	afterPropertiesSet()
protected MessageChannel	getChannel()
protected MessageMapper<?,T>	getMessageMapper()
protected void	initialize() Subclasses may implement this to take advantage of the initialization callback.
protected boolean	isInitialized()
protected boolean	sendToChannel(T object)
void	setChannel(MessageChannel channel)
void	setMessageMapper(MessageMapper<?,T> mapper)
void	setSendTimeout(long sendTimeout)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected org.apache.commons.logging.Log logger

Constructor Detail

AbstractSourceAdapter

public AbstractSourceAdapter()

Method Detail

setChannel

public void setChannel(MessageChannel channel)

Specified by:

setChannel in interface SourceAdapter

getChannel

protected MessageChannel getChannel()

setSendTimeout

public void setSendTimeout(long sendTimeout)

setMessageMapper

public void setMessageMapper(MessageMapper<?,T> mapper)

getMessageMapper

protected MessageMapper<?,T> getMessageMapper()

afterPropertiesSet

public final void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

isInitialized

protected boolean isInitialized()

initialize

protected void initialize()

Subclasses may implement this to take advantage of the initialization callback.

sendToChannel

protected boolean sendToChannel(T object)