org.apache.flume.api

Class SSLContextAwareAbstractRpcClient

java.lang.Object

org.apache.flume.api.AbstractRpcClient

org.apache.flume.api.SSLContextAwareAbstractRpcClient

All Implemented Interfaces:

RpcClient

Direct Known Subclasses:

NettyAvroRpcClient, ThriftRpcClient

public abstract class SSLContextAwareAbstractRpcClient
extends AbstractRpcClient

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	enableSsl
protected Set<String>	excludeCipherSuites
protected Set<String>	excludeProtocols
protected Set<String>	includeCipherSuites
protected Set<String>	includeProtocols
protected boolean	trustAllCerts
protected String	truststore
protected String	truststorePassword
protected String	truststoreType

Fields inherited from class org.apache.flume.api.AbstractRpcClient

batchSize, connectTimeout, requestTimeout

Constructor Summary

Constructors

Constructor and Description
SSLContextAwareAbstractRpcClient()

Method Summary

Modifier and Type	Method and Description
protected void	configureSSL(Properties properties)

Methods inherited from class org.apache.flume.api.AbstractRpcClient

append, appendBatch, close, configure, getBatchSize, isActive, parseBatchSize

Methods inherited from class java.lang.Object

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

Field Detail

enableSsl

protected boolean enableSsl

trustAllCerts

protected boolean trustAllCerts

truststore

protected String truststore

truststorePassword

protected String truststorePassword

truststoreType

protected String truststoreType

excludeProtocols

protected final Set<String> excludeProtocols

includeProtocols

protected final Set<String> includeProtocols

excludeCipherSuites

protected final Set<String> excludeCipherSuites

includeCipherSuites

protected final Set<String> includeCipherSuites

Constructor Detail

SSLContextAwareAbstractRpcClient

public SSLContextAwareAbstractRpcClient()

Method Detail

configureSSL

protected void configureSSL(Properties properties)
                     throws FlumeException

Throws:

FlumeException