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 Summary
Modifier and TypeFieldDescriptionprotected org.apache.storm.thrift.protocol.TProtocol
protected boolean
-
Constructor Summary
ConstructorDescriptionThriftClient
(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 Summary
Modifier and TypeMethodDescriptionvoid
close()
protected File
getKeyStoreFile
(String keyStorePass) Function to create a keystore and return the keystore file.protected PrivateKey
Get the private key using BouncyCastle library from a PKCS#1 format file.void
org.apache.storm.thrift.transport.TTransport
-
Field Details
-
protocol
protected org.apache.storm.thrift.protocol.TProtocol protocol -
retryForever
protected boolean retryForever
-
-
Constructor Details
-
ThriftClient
-
ThriftClient
-
ThriftClient
-
-
Method Details
-
transport
public org.apache.storm.thrift.transport.TTransport transport() -
getPrivateKey
Get the private key using BouncyCastle library from a PKCS#1 format file.- Returns:
- The Private Key
- Throws:
IOException
- The IOException
-
getKeyStoreFile
protected 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
- CertificateExceptionKeyStoreException
- KeyStoreExceptionIOException
- IOExceptionNoSuchAlgorithmException
- NoSuchAlgorithmException
-
reconnect
public void reconnect() -
close
public void close()- Specified by:
close
in interfaceAutoCloseable
-