Package com.dtsx.astra.sdk.streaming

Class PulsarAdminProvider

java.lang.Object

com.dtsx.astra.sdk.streaming.PulsarAdminProvider

All Implemented Interfaces:

Supplier<org.apache.pulsar.client.admin.PulsarAdmin>

public class PulsarAdminProvider
extends Object
implements Supplier<org.apache.pulsar.client.admin.PulsarAdmin>

Delegate PulsarClient to a sub class.

Author:

Cedrick LUNVEN (@clunven)

Constructor Summary

Constructors

Constructor	Description
PulsarAdminProvider(String webServiceUrl, String pulsarToken)	Default constructor.

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.client.admin.PulsarAdmin	get()

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarAdminProvider

public PulsarAdminProvider(String webServiceUrl,
 String pulsarToken)

Default constructor.

Parameters:

webServiceUrl - webServiceUrl Url

pulsarToken - pulsar token

Method Details

get

public org.apache.pulsar.client.admin.PulsarAdmin get()

Specified by:

get in interface Supplier<org.apache.pulsar.client.admin.PulsarAdmin>