org.apache.flume.source

Class SslContextAwareAbstractSource

java.lang.Object

org.apache.flume.source.AbstractSource

org.apache.flume.source.SslContextAwareAbstractSource

All Implemented Interfaces:

LifecycleAware, NamedComponent, Source

Direct Known Subclasses:

AvroSource, HTTPSource, MultiportSyslogTCPSource, SyslogTcpSource, ThriftSource

public abstract class SslContextAwareAbstractSource
extends AbstractSource

Constructor Summary

Constructors

Constructor and Description
SslContextAwareAbstractSource()

Method Summary

Modifier and Type	Method and Description
protected void	configureSsl(Context context)
Set<String>	getExcludeCipherSuites()
Set<String>	getExcludeProtocols()
protected String[]	getFilteredCipherSuites(SSLParameters sslParameters)
protected String[]	getFilteredProtocols(SSLParameters sslParameters)
Set<String>	getIncludeCipherSuites()
Set<String>	getIncludeProtocols()
String	getKeystore()
String	getKeystorePassword()
String	getKeystoreType()
protected Supplier<Optional<SSLContext>>	getSslContextSupplier()
protected Supplier<Optional<SSLEngine>>	getSslEngineSupplier(boolean useClientMode)
boolean	isSslEnabled()

Methods inherited from class org.apache.flume.source.AbstractSource

getChannelProcessor, getLifecycleState, getName, setChannelProcessor, setName, start, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SslContextAwareAbstractSource

public SslContextAwareAbstractSource()

Method Detail

getKeystore

public String getKeystore()

getKeystorePassword

public String getKeystorePassword()

getKeystoreType

public String getKeystoreType()

getExcludeProtocols

public Set<String> getExcludeProtocols()

getIncludeProtocols

public Set<String> getIncludeProtocols()

getExcludeCipherSuites

public Set<String> getExcludeCipherSuites()

getIncludeCipherSuites

public Set<String> getIncludeCipherSuites()

isSslEnabled

public boolean isSslEnabled()

configureSsl

protected void configureSsl(Context context)

getSslContextSupplier

protected Supplier<Optional<SSLContext>> getSslContextSupplier()

getSslEngineSupplier

protected Supplier<Optional<SSLEngine>> getSslEngineSupplier(boolean useClientMode)

getFilteredProtocols

protected String[] getFilteredProtocols(SSLParameters sslParameters)

getFilteredCipherSuites

protected String[] getFilteredCipherSuites(SSLParameters sslParameters)