Package org.apache.nifi.processors.standard.ftp

Class NifiFtpServer.Builder

java.lang.Object

org.apache.nifi.processors.standard.ftp.NifiFtpServer.Builder

Enclosing class:

NifiFtpServer

public static class NifiFtpServer.Builder
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private String	bindAddress
private static final String	HOME_DIRECTORY
private String	password
private int	port
private org.apache.nifi.processor.Relationship	relationshipSuccess
private AtomicReference<org.apache.nifi.processor.ProcessSessionFactory>	sessionFactory
private CountDownLatch	sessionFactorySetSignal
private SSLContextProvider	sslContextProvider
private String	username

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
NifiFtpServer.Builder	bindAddress(String bindAddress)
NifiFtpServer	build()
private org.apache.ftpserver.ftplet.User	createAnonymousUser(String homeDirectory, List<org.apache.ftpserver.ftplet.Authority> authorities)
private org.apache.ftpserver.ConnectionConfig	createConnectionConfig(boolean anonymousLoginEnabled)
private org.apache.ftpserver.listener.Listener	createListener(String bindAddress, int port, SSLContextProvider sslContextProvider)
private org.apache.ftpserver.ftplet.User	createNamedUser(String username, String password, String homeDirectory, List<org.apache.ftpserver.ftplet.Authority> authorities)
private org.apache.ftpserver.ftplet.User	createUser(String username, String password, String homeDirectory)
NifiFtpServer.Builder	password(String password)
NifiFtpServer.Builder	port(int port)
NifiFtpServer.Builder	relationshipSuccess(org.apache.nifi.processor.Relationship relationship)
NifiFtpServer.Builder	sessionFactory(AtomicReference<org.apache.nifi.processor.ProcessSessionFactory> sessionFactory)
NifiFtpServer.Builder	sessionFactorySetSignal(CountDownLatch sessionFactorySetSignal)
NifiFtpServer.Builder	sslContextProvider(SSLContextProvider sslContextProvider)
NifiFtpServer.Builder	username(String username)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

HOME_DIRECTORY

private static final String HOME_DIRECTORY

See Also:

• Constant Field Values

sessionFactory

private AtomicReference<org.apache.nifi.processor.ProcessSessionFactory> sessionFactory

sessionFactorySetSignal

private CountDownLatch sessionFactorySetSignal

relationshipSuccess

private org.apache.nifi.processor.Relationship relationshipSuccess

bindAddress

private String bindAddress

port

private int port

username

private String username

password

private String password

sslContextProvider

private SSLContextProvider sslContextProvider

Constructor Details

Builder

public Builder()

Method Details

sessionFactory

public NifiFtpServer.Builder sessionFactory(AtomicReference<org.apache.nifi.processor.ProcessSessionFactory> sessionFactory)

sessionFactorySetSignal

public NifiFtpServer.Builder sessionFactorySetSignal(CountDownLatch sessionFactorySetSignal)

relationshipSuccess

public NifiFtpServer.Builder relationshipSuccess(org.apache.nifi.processor.Relationship relationship)

bindAddress

public NifiFtpServer.Builder bindAddress(String bindAddress)

port

public NifiFtpServer.Builder port(int port)

username

public NifiFtpServer.Builder username(String username)

password

public NifiFtpServer.Builder password(String password)

sslContextProvider

public NifiFtpServer.Builder sslContextProvider(SSLContextProvider sslContextProvider)

build

public NifiFtpServer build()
                    throws org.apache.nifi.processor.exception.ProcessException

Throws:

org.apache.nifi.processor.exception.ProcessException

createConnectionConfig

private org.apache.ftpserver.ConnectionConfig createConnectionConfig(boolean anonymousLoginEnabled)

createListener

private org.apache.ftpserver.listener.Listener createListener(String bindAddress,
 int port,
 SSLContextProvider sslContextProvider)
                                                       throws org.apache.ftpserver.FtpServerConfigurationException

Throws:

org.apache.ftpserver.FtpServerConfigurationException

createUser

private org.apache.ftpserver.ftplet.User createUser(String username,
 String password,
 String homeDirectory)

createAnonymousUser

private org.apache.ftpserver.ftplet.User createAnonymousUser(String homeDirectory,
 List<org.apache.ftpserver.ftplet.Authority> authorities)

createNamedUser

private org.apache.ftpserver.ftplet.User createNamedUser(String username,
 String password,
 String homeDirectory,
 List<org.apache.ftpserver.ftplet.Authority> authorities)