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

java.lang.Object
  org.springframework.integration.util.AbstractExpressionEvaluator
      org.springframework.integration.endpoint.AbstractMessageSource<T>

All Implemented Interfaces:

BeanFactoryAware, MessageSource<T>

Direct Known Subclasses:

AttributePollingMessageSource, ExpressionEvaluatingMessageSource, MethodInvokingMessageSource

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

Since:

2.0

Constructor Summary

AbstractMessageSource()

Method Summary

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,Expression> headerExpressions)

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

evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getEvaluationContext, setBeanFactory, setBeanResolver, 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,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.