Package io.quarkus.pulsar

Class QuarkusPulsarKeyStoreAuthentication

java.lang.Object

io.quarkus.pulsar.QuarkusPulsarKeyStoreAuthentication

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, org.apache.pulsar.client.api.Authentication

public class QuarkusPulsarKeyStoreAuthentication
extends Object
implements org.apache.pulsar.client.api.Authentication

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BEGIN_CERT
static final String	END_CERT
static final String	LINE_SEPARATOR

Constructor Summary

Constructors

Constructor	Description
QuarkusPulsarKeyStoreAuthentication(io.quarkus.tls.TlsConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,String> authParams)
static io.vertx.core.buffer.Buffer	formatCrtFileContents(Certificate certificate)
org.apache.pulsar.client.api.AuthenticationDataProvider	getAuthData()
String	getAuthMethodName()
void	start()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pulsar.client.api.Authentication

authenticationStage, getAuthData, newRequestHeader

Field Details

BEGIN_CERT

public static final String BEGIN_CERT

See Also:

• Constant Field Values

END_CERT

public static final String END_CERT

See Also:

• Constant Field Values

LINE_SEPARATOR

public static final String LINE_SEPARATOR

Constructor Details

QuarkusPulsarKeyStoreAuthentication

public QuarkusPulsarKeyStoreAuthentication(io.quarkus.tls.TlsConfiguration configuration)

Method Details

getAuthMethodName

public String getAuthMethodName()

Specified by:

getAuthMethodName in interface org.apache.pulsar.client.api.Authentication

configure

public void configure(Map<String,String> authParams)

Specified by:

configure in interface org.apache.pulsar.client.api.Authentication

start

public void start()
           throws org.apache.pulsar.client.api.PulsarClientException

Specified by:

start in interface org.apache.pulsar.client.api.Authentication

Throws:

org.apache.pulsar.client.api.PulsarClientException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getAuthData

public org.apache.pulsar.client.api.AuthenticationDataProvider getAuthData()
                                                                    throws org.apache.pulsar.client.api.PulsarClientException

Specified by:

getAuthData in interface org.apache.pulsar.client.api.Authentication

Throws:

org.apache.pulsar.client.api.PulsarClientException

formatCrtFileContents

public static io.vertx.core.buffer.Buffer formatCrtFileContents(Certificate certificate)
                                                         throws CertificateEncodingException

Throws:

CertificateEncodingException