Class DefaultPulsarClientFactory

java.lang.Object

org.apache.pulsar.spring.core.DefaultPulsarClientFactory

All Implemented Interfaces:

PulsarClientFactory, Aware, EnvironmentAware

public class DefaultPulsarClientFactory
extends Object
implements PulsarClientFactory, EnvironmentAware

Default implementation for PulsarClientFactory.

Author:

Soby Chacko, Chris Bono

Constructor Summary

Constructors

Constructor	Description
DefaultPulsarClientFactory(String serviceUrl)	Construct a factory that creates clients using a default Pulsar client builder with no modifications other than the specified service url.
DefaultPulsarClientFactory(PulsarClientBuilderCustomizer customizer)	Construct a factory that creates clients using a customized Pulsar client builder.

Method Summary

Modifier and Type	Method	Description
org.apache.pulsar.client.api.PulsarClient	createClient()	Create a client.
void	setEnvironment(Environment environment)

Methods inherited from class Object

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

Constructor Details

DefaultPulsarClientFactory

public DefaultPulsarClientFactory(String serviceUrl)

Construct a factory that creates clients using a default Pulsar client builder with no modifications other than the specified service url.

Parameters:

serviceUrl - the service url

DefaultPulsarClientFactory

public DefaultPulsarClientFactory(PulsarClientBuilderCustomizer customizer)

Construct a factory that creates clients using a customized Pulsar client builder.

Parameters:

customizer - the customizer to apply to the builder

Method Details

createClient

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

Description copied from interface: PulsarClientFactory

Create a client.

Specified by:

createClient in interface PulsarClientFactory

Returns:

the created client instance

setEnvironment

public void setEnvironment(Environment environment)

Specified by:

setEnvironment in interface EnvironmentAware