Package org.springframework.pulsar.config

Class PulsarClientFactoryBean

java.lang.Object

org.springframework.beans.factory.config.AbstractFactoryBean<org.apache.pulsar.client.api.PulsarClient>

org.springframework.pulsar.config.PulsarClientFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<org.apache.pulsar.client.api.PulsarClient>, InitializingBean

public class PulsarClientFactoryBean
extends AbstractFactoryBean<org.apache.pulsar.client.api.PulsarClient>

FactoryBean implementation for the PulsarClient.

Author:

Soby Chacko, Chris Bono

Field Summary

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
PulsarClientFactoryBean(PulsarClientConfiguration pulsarClientConfiguration)

Method Summary

Modifier and Type	Method	Description
protected org.apache.pulsar.client.api.PulsarClient	createInstance()
protected void	destroyInstance(org.apache.pulsar.client.api.PulsarClient instance)
Class<?>	getObjectType()

Methods inherited from class org.springframework.beans.factory.config.AbstractFactoryBean

afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarClientFactoryBean

public PulsarClientFactoryBean(PulsarClientConfiguration pulsarClientConfiguration)

Method Details

getObjectType

public Class<?> getObjectType()

Specified by:

getObjectType in interface FactoryBean<org.apache.pulsar.client.api.PulsarClient>

Specified by:

getObjectType in class AbstractFactoryBean<org.apache.pulsar.client.api.PulsarClient>

createInstance

protected org.apache.pulsar.client.api.PulsarClient createInstance()
                                                            throws Exception

Specified by:

createInstance in class AbstractFactoryBean<org.apache.pulsar.client.api.PulsarClient>

Throws:

Exception

destroyInstance

protected void destroyInstance(@Nullable
 org.apache.pulsar.client.api.PulsarClient instance)
                        throws Exception

Overrides:

destroyInstance in class AbstractFactoryBean<org.apache.pulsar.client.api.PulsarClient>

Throws:

Exception