Spring Integration

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

java.lang.Object
  extended by org.springframework.integration.util.AbstractExpressionEvaluator
      extended by org.springframework.integration.endpoint.AbstractMessageSource<T>
All Implemented Interfaces:
org.springframework.beans.factory.BeanFactoryAware, MessageSource<T>
Direct Known Subclasses:
AttributePollingMessageSource, ExpressionEvaluatingMessageSource, MethodInvokingMessageSource, ResourceRetrievingMessageSource

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

Since:
2.0
Author:
Mark Fisher, Oleg Zhurakousky

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,org.springframework.expression.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,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.


Spring Integration