RssReader.java

package blog;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.integration.core.MessageSource;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.Message;

public class RssReader implements MessageSource<String> {
    private static Logger logger = LoggerFactory.getLogger(RssReader.class);
    public Message<String> receive() {
        logger.debug("readRssFeed method is called");
        return MessageBuilder.withPayload("test").setHeader("feedid", "thefeed").build();
    }
}