Package com.dtsx.astra.sdk.streaming

Class PulsarClientProvider

java.lang.Object

com.dtsx.astra.sdk.streaming.PulsarClientProvider

All Implemented Interfaces:

Supplier<org.apache.pulsar.client.api.PulsarClient>

public class PulsarClientProvider
extends Object
implements Supplier<org.apache.pulsar.client.api.PulsarClient>

Delegate PulsarClient to a sub class.

Constructor Summary

Constructors

Constructor	Description
PulsarClientProvider(String brokerUrl, String pulsarToken)	Default constructor.

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.client.api.PulsarClient	get()

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarClientProvider

public PulsarClientProvider(String brokerUrl,
 String pulsarToken)

Default constructor.

Parameters:

brokerUrl - broker Url

pulsarToken - pulsar token

Method Details

get

public org.apache.pulsar.client.api.PulsarClient get()

Specified by:

get in interface Supplier<org.apache.pulsar.client.api.PulsarClient>