public class MessageSources
extends java.lang.Object
MessageSourceSpecs from Namespace Factories.
*IntegrationFlows.from(IntegrationFlows.MessageSourcesFunction)| Modifier and Type | Method and Description |
|---|---|
FeedEntryMessageSourceSpec |
feed(java.net.URL feedUrl,
java.lang.String metadataKey)
|
FileInboundChannelAdapterSpec |
file(java.io.File directory)
Factory for the
FileInboundChannelAdapterSpec |
FileInboundChannelAdapterSpec |
file(java.io.File directory,
java.util.Comparator<java.io.File> receptionOrderComparator)
Factory for the
FileInboundChannelAdapterSpec |
FtpInboundChannelAdapterSpec |
ftp(org.springframework.integration.file.remote.session.SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory)
Factory for the
FtpInboundChannelAdapterSpec |
FtpInboundChannelAdapterSpec |
ftp(org.springframework.integration.file.remote.session.SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory,
java.util.Comparator<java.io.File> receptionOrderComparator)
Factory for the
FtpInboundChannelAdapterSpec |
ImapMailInboundChannelAdapterSpec |
imap()
Factory for the
ImapMailInboundChannelAdapterSpec |
ImapMailInboundChannelAdapterSpec |
imap(java.lang.String url)
Factory for the
ImapMailInboundChannelAdapterSpec |
JmsInboundChannelAdapterSpec.JmsInboundChannelSpecTemplateAware |
jms(javax.jms.ConnectionFactory connectionFactory)
Factory for the
JmsInboundChannelAdapterSpec |
JmsInboundChannelAdapterSpec<? extends JmsInboundChannelAdapterSpec<?>> |
jms(org.springframework.jms.core.JmsTemplate jmsTemplate)
Factory for the
JmsInboundChannelAdapterSpec |
Pop3MailInboundChannelAdapterSpec |
pop3()
Factory for the
Pop3MailInboundChannelAdapterSpec |
Pop3MailInboundChannelAdapterSpec |
pop3(java.lang.String url)
Factory for the
Pop3MailInboundChannelAdapterSpec |
Pop3MailInboundChannelAdapterSpec |
pop3(java.lang.String host,
int port,
java.lang.String username,
java.lang.String password)
Factory for the
Pop3MailInboundChannelAdapterSpec |
Pop3MailInboundChannelAdapterSpec |
pop3(java.lang.String host,
java.lang.String username,
java.lang.String password)
Factory for the
Pop3MailInboundChannelAdapterSpec |
ScriptMessageSourceSpec |
script(org.springframework.core.io.Resource scriptResource)
Factory for the
ScriptMessageSourceSpec based on the Resource. |
ScriptMessageSourceSpec |
script(java.lang.String scriptLocation)
Factory for the
ScriptMessageSourceSpec based on the script location. |
SftpInboundChannelAdapterSpec |
sftp(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sessionFactory)
Factory for the
SftpInboundChannelAdapterSpec |
SftpInboundChannelAdapterSpec |
sftp(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sessionFactory,
java.util.Comparator<java.io.File> receptionOrderComparator)
Factory for the
SftpInboundChannelAdapterSpec |
public FileInboundChannelAdapterSpec file(java.io.File directory)
FileInboundChannelAdapterSpecdirectory - the based directory to pollpublic FileInboundChannelAdapterSpec file(java.io.File directory, java.util.Comparator<java.io.File> receptionOrderComparator)
FileInboundChannelAdapterSpecdirectory - the based directory to pollreceptionOrderComparator - the Comparator to order the files
in the internal queuepublic FtpInboundChannelAdapterSpec ftp(org.springframework.integration.file.remote.session.SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory)
FtpInboundChannelAdapterSpecsessionFactory - the SessionFactory for FTPpublic FtpInboundChannelAdapterSpec ftp(org.springframework.integration.file.remote.session.SessionFactory<org.apache.commons.net.ftp.FTPFile> sessionFactory, java.util.Comparator<java.io.File> receptionOrderComparator)
FtpInboundChannelAdapterSpecsessionFactory - the SessionFactory for FTPreceptionOrderComparator - the Comparator to order the files
in the internal queuepublic SftpInboundChannelAdapterSpec sftp(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sessionFactory)
SftpInboundChannelAdapterSpecsessionFactory - the SessionFactory for SFTPpublic SftpInboundChannelAdapterSpec sftp(org.springframework.integration.file.remote.session.SessionFactory<com.jcraft.jsch.ChannelSftp.LsEntry> sessionFactory, java.util.Comparator<java.io.File> receptionOrderComparator)
SftpInboundChannelAdapterSpecsessionFactory - the SessionFactory for SFTPreceptionOrderComparator - the Comparator to order the files
in the internal queuepublic JmsInboundChannelAdapterSpec<? extends JmsInboundChannelAdapterSpec<?>> jms(org.springframework.jms.core.JmsTemplate jmsTemplate)
JmsInboundChannelAdapterSpecjmsTemplate - the JmsTemplate to usepublic JmsInboundChannelAdapterSpec.JmsInboundChannelSpecTemplateAware jms(javax.jms.ConnectionFactory connectionFactory)
JmsInboundChannelAdapterSpecconnectionFactory - the ConnectionFactory to usepublic ImapMailInboundChannelAdapterSpec imap()
ImapMailInboundChannelAdapterSpecpublic ImapMailInboundChannelAdapterSpec imap(java.lang.String url)
ImapMailInboundChannelAdapterSpecurl - the IMAP urlpublic Pop3MailInboundChannelAdapterSpec pop3()
Pop3MailInboundChannelAdapterSpecpublic Pop3MailInboundChannelAdapterSpec pop3(java.lang.String url)
Pop3MailInboundChannelAdapterSpecurl - the POP3 urlpublic Pop3MailInboundChannelAdapterSpec pop3(java.lang.String host, java.lang.String username, java.lang.String password)
Pop3MailInboundChannelAdapterSpechost - the POP3 hostusername - the user name to connect to POP3password - the password to connect to POP3public Pop3MailInboundChannelAdapterSpec pop3(java.lang.String host, int port, java.lang.String username, java.lang.String password)
Pop3MailInboundChannelAdapterSpechost - the POP3 hostport - the POP3 portusername - the user name to connect to POP3password - the password to connect to POP3public ScriptMessageSourceSpec script(org.springframework.core.io.Resource scriptResource)
ScriptMessageSourceSpec based on the Resource.
The Resource must represent the real file and can be injected like:
@Value("com/my/project/scripts/FilterScript.groovy")
private Resource filterScript;
scriptResource - the script ResourceScriptMessageSourceSpecpublic ScriptMessageSourceSpec script(java.lang.String scriptLocation)
ScriptMessageSourceSpec based on the script location.scriptLocation - the path to the script file.
file:, ftp:, s3: etc.
The classpath: can be omitted.ScriptMessageSourceSpecpublic FeedEntryMessageSourceSpec feed(java.net.URL feedUrl, java.lang.String metadataKey)
feedUrl - the URL for Feed resource.metadataKey - the metadata key to the last entry after fetching.FeedEntryMessageSourceSpec