Class MessageProcessorMessageSource

All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, MessageSource<Object>, IntegrationPattern, NamedComponent, IntegrationInboundManagement, IntegrationManagement

public class MessageProcessorMessageSource extends AbstractMessageSource<Object>
The MessageSource strategy implementation to produce a Message from underlying messageProcessor for polling endpoints.
Since:
5.0
  • Constructor Details

    • MessageProcessorMessageSource

      public MessageProcessorMessageSource(MessageProcessor<?> messageProcessor)
  • Method Details

    • getComponentType

      public String getComponentType()
    • doReceive

      protected Object doReceive()
      Description copied from class: AbstractMessageSource
      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; also can be AbstractIntegrationMessageBuilder which is used for additional headers population.
      Specified by:
      doReceive in class AbstractMessageSource<Object>
      Returns:
      The value returned.