public class MessageSources
extends java.lang.Object
MessageSourceSpec
s 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)
FileInboundChannelAdapterSpec
directory
- the based directory to pollpublic FileInboundChannelAdapterSpec file(java.io.File directory, java.util.Comparator<java.io.File> receptionOrderComparator)
FileInboundChannelAdapterSpec
directory
- 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)
FtpInboundChannelAdapterSpec
sessionFactory
- 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)
FtpInboundChannelAdapterSpec
sessionFactory
- 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)
SftpInboundChannelAdapterSpec
sessionFactory
- 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)
SftpInboundChannelAdapterSpec
sessionFactory
- the SessionFactory
for SFTPreceptionOrderComparator
- the Comparator
to order the files
in the internal queuepublic JmsInboundChannelAdapterSpec<? extends JmsInboundChannelAdapterSpec<?>> jms(org.springframework.jms.core.JmsTemplate jmsTemplate)
JmsInboundChannelAdapterSpec
jmsTemplate
- the JmsTemplate
to usepublic JmsInboundChannelAdapterSpec.JmsInboundChannelSpecTemplateAware jms(javax.jms.ConnectionFactory connectionFactory)
JmsInboundChannelAdapterSpec
connectionFactory
- the ConnectionFactory
to usepublic ImapMailInboundChannelAdapterSpec imap()
ImapMailInboundChannelAdapterSpec
public ImapMailInboundChannelAdapterSpec imap(java.lang.String url)
ImapMailInboundChannelAdapterSpec
url
- the IMAP urlpublic Pop3MailInboundChannelAdapterSpec pop3()
Pop3MailInboundChannelAdapterSpec
public Pop3MailInboundChannelAdapterSpec pop3(java.lang.String url)
Pop3MailInboundChannelAdapterSpec
url
- the POP3 urlpublic Pop3MailInboundChannelAdapterSpec pop3(java.lang.String host, java.lang.String username, java.lang.String password)
Pop3MailInboundChannelAdapterSpec
host
- 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)
Pop3MailInboundChannelAdapterSpec
host
- 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 Resource
ScriptMessageSourceSpec
public 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.ScriptMessageSourceSpec
public 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