org.springframework.integration.endpoint

Class AbstractMessageSource<T>

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<T>

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, MessageSource<T>

Direct Known Subclasses:

AttributePollingMessageSource, ExpressionEvaluatingMessageSource, MBeanTreePollingMessageSource, MethodInvokingMessageSource, ResourceRetrievingMessageSource

public abstract class AbstractMessageSource<T>
extends AbstractExpressionEvaluator
implements MessageSource<T>

Since:

2.0

Author:

Mark Fisher, Oleg Zhurakousky

Constructor Summary

Constructors

Constructor and Description
AbstractMessageSource()

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract java.lang.Object	doReceive() Subclasses must implement this method.
Message<T>	receive() Retrieve the next available message from this source.
void	setHeaderExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> headerExpressions)

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getEvaluationContext, getEvaluationContext, setBeanFactory, setConversionService

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractMessageSource

public AbstractMessageSource()

Method Detail

setHeaderExpressions

public void setHeaderExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> headerExpressions)

receive

public final Message<T> receive()

Description copied from interface: MessageSource

Retrieve the next available message from this source. Returns null if no message is available.

Specified by:

receive in interface MessageSource<T>

doReceive

protected abstract java.lang.Object doReceive()

Subclasses must implement this method. Typically the returned value will be the payload of type T, but the returned value may also be a Message instance whose payload is of type T.