Package org.apache.storm.security.auth
Class ThriftClient
java.lang.Object
org.apache.storm.security.auth.ThriftClient
- All Implemented Interfaces:
- AutoCloseable
- Direct Known Subclasses:
- DRPCClient,- DRPCInvocationsClient,- NimbusClient,- SupervisorClient
- 
Field SummaryFieldsModifier and TypeFieldDescriptionprotected org.apache.storm.thrift.protocol.TProtocolprotected boolean
- 
Constructor SummaryConstructorsConstructorDescriptionThriftClient(Map<String, Object> topoConf, ThriftConnectionType type, String host) ThriftClient(Map<String, Object> topoConf, ThriftConnectionType type, String host, Integer port, Integer timeout) ThriftClient(Map<String, Object> topoConf, ThriftConnectionType type, String host, Integer port, Integer timeout, String asUser) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidclose()protected FilegetKeyStoreFile(String keyStorePass) Function to create a keystore and return the keystore file.protected PrivateKeyGet the private key using BouncyCastle library from a PKCS#1 format file.voidorg.apache.storm.thrift.transport.TTransport
- 
Field Details- 
protocolprotected org.apache.storm.thrift.protocol.TProtocol protocol
- 
retryForeverprotected boolean retryForever
 
- 
- 
Constructor Details- 
ThriftClient
- 
ThriftClient
- 
ThriftClient
 
- 
- 
Method Details- 
transportpublic org.apache.storm.thrift.transport.TTransport transport()
- 
getPrivateKeyGet the private key using BouncyCastle library from a PKCS#1 format file.- Returns:
- The Private Key
- Throws:
- IOException- The IOException
 
- 
getKeyStoreFileprotected File getKeyStoreFile(String keyStorePass) throws CertificateException, KeyStoreException, IOException, NoSuchAlgorithmException Function to create a keystore and return the keystore file.- Parameters:
- keyStorePass- The keystore password.
- Returns:
- The keystore file
- Throws:
- CertificateException- CertificateException
- KeyStoreException- KeyStoreException
- IOException- IOException
- NoSuchAlgorithmException- NoSuchAlgorithmException
 
- 
reconnectpublic void reconnect()
- 
closepublic void close()- Specified by:
- closein interface- AutoCloseable
 
 
-